NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::RequestHandlerService Member List

This is the complete list of members for NES::RequestHandlerService, including all inherited members.

queueAddKeyDistributionEntryRequest(const std::string &logicalSourceName, const std::string &physicalSourceName, WorkerId workerId, const std::string &value) constNES::RequestHandlerService
queueGetAllLogicalSourcesRequest() constNES::RequestHandlerService
queueGetLogicalSourceSchemaRequest(std::string logicelSourceName) constNES::RequestHandlerService
queueGetPhysicalSourcesRequest(std::string logicelSourceName) constNES::RequestHandlerService
queueISQPRequest(const std::vector< RequestProcessor::ISQPEventPtr > &isqpEvents)NES::RequestHandlerService
queueRegisterLogicalSourceRequest(const std::string &logicalSourceName, SchemaPtr schema) constNES::RequestHandlerService
queueRegisterPhysicalSourceRequest(std::vector< RequestProcessor::PhysicalSourceDefinition > additions, WorkerId workerId) constNES::RequestHandlerService
queueUnregisterAllPhysicalSourcesByWorkerRequest(WorkerId workerId) constNES::RequestHandlerService
queueUnregisterLogicalSourceRequest(const std::string &logicalSourceName) constNES::RequestHandlerService
queueUnregisterPhysicalSourceRequest(const std::string &physicalSourceName, const std::string &logicalSourceName, WorkerId workerId) constNES::RequestHandlerService
queueUpdateLogicalSourceRequest(const std::string &logicalSourceName, SchemaPtr schema) constNES::RequestHandlerService
RequestHandlerService(Configurations::OptimizerConfiguration optimizerConfiguration, const QueryParsingServicePtr &queryParsingService, const Catalogs::Query::QueryCatalogPtr &queryCatalog, const Catalogs::Source::SourceCatalogPtr &sourceCatalog, const Catalogs::UDF::UDFCatalogPtr &udfCatalog, const NES::RequestProcessor::AsyncRequestProcessorPtr &asyncRequestExecutor, const z3::ContextPtr &z3Context, const Statistic::AbstractStatisticQueryGeneratorPtr &statisticQueryGenerator, const Statistic::StatisticRegistryPtr &statisticRegistry, const Optimizer::PlacementAmendmentHandlerPtr &placementAmendmentHandler)NES::RequestHandlerServiceexplicit
trackStatisticRequest(const Statistic::CharacteristicPtr &characteristic, const Windowing::WindowTypePtr &window, const Statistic::TriggerConditionPtr &triggerCondition, const Statistic::SendingPolicyPtr &sendingPolicy, std::function< void(Statistic::CharacteristicPtr)> callBack)NES::RequestHandlerService
trackStatisticRequest(const Statistic::CharacteristicPtr &characteristic, const Windowing::WindowTypePtr &window)NES::RequestHandlerService
validateAndQueueAddQueryRequest(const std::string &queryString, const Optimizer::PlacementStrategy placementStrategy)NES::RequestHandlerService
validateAndQueueAddQueryRequest(const QueryPlanPtr &queryPlan, const Optimizer::PlacementStrategy placementStrategy)NES::RequestHandlerService
validateAndQueueExplainQueryRequest(const QueryPlanPtr &queryPlan, const Optimizer::PlacementStrategy placementStrategy)NES::RequestHandlerService
validateAndQueueFailQueryRequest(SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, const std::string &failureReason)NES::RequestHandlerService
validateAndQueueStopQueryRequest(QueryId queryId)NES::RequestHandlerService