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

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

AbstractQueryManager()=deleteNES::Runtime::AbstractQueryManager
AbstractQueryManager(const AbstractQueryManager &)=deleteNES::Runtime::AbstractQueryManager
AbstractQueryManager(std::shared_ptr< AbstractQueryStatusListener > queryStatusListener, std::vector< BufferManagerPtr > bufferManagers, WorkerId nodeEngineId, uint16_t numThreads, HardwareManagerPtr hardwareManager, uint64_t numberOfBuffersPerEpoch, std::vector< uint64_t > workerToCoreMapping={})NES::Runtime::AbstractQueryManagerexplicit
addEndOfStream(DataSourcePtr source, Runtime::QueryTerminationType graceful=Runtime::QueryTerminationType::Graceful)NES::Runtime::AbstractQueryManager
addFailureEndOfStream(DataSourcePtr source)NES::Runtime::AbstractQueryManagerprotected
addHardEndOfStream(DataSourcePtr source)NES::Runtime::AbstractQueryManagerprotected
addSoftEndOfStream(DataSourcePtr source)NES::Runtime::AbstractQueryManagerprotected
addWorkForNextPipeline(TupleBuffer &buffer, Execution::SuccessorExecutablePipeline executable, uint32_t queueId=0) overrideNES::Runtime::MultiQueueQueryManagervirtual
asyncTaskExecutorNES::Runtime::AbstractQueryManagerprotected
bufferManagersNES::Runtime::AbstractQueryManagerprotected
canTriggerEndOfStream(DataSourcePtr source, Runtime::QueryTerminationType)NES::Runtime::AbstractQueryManager
completedWork(Task &task, WorkerContext &workerContext)NES::Runtime::AbstractQueryManagerprotected
decomposeQueryToSourceIdMappingNES::Runtime::AbstractQueryManagerprotected
destroy() overrideNES::Runtime::MultiQueueQueryManagervirtual
failExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &qep)NES::Runtime::AbstractQueryManager
getBufferManager()NES::Runtime::AbstractQueryManagerinline
getCurrentTaskSum()NES::Runtime::AbstractQueryManager
getExecutablePlanIdsForSource(DataSourcePtr source) constNES::Runtime::AbstractQueryManager
getNextTaskId()NES::Runtime::AbstractQueryManagerprotected
getNodeId() constNES::Runtime::AbstractQueryManager
getNumberOfBuffersPerEpoch() constNES::Runtime::MultiQueueQueryManager
getNumberOfTasksInWorkerQueues() const overrideNES::Runtime::MultiQueueQueryManagervirtual
getNumberOfWorkerThreads()NES::Runtime::AbstractQueryManager
getQepStatus(DecomposedQueryIdWithVersion decomposedQueryIdWithVersion)NES::Runtime::AbstractQueryManager
getQueryExecutionPlan(DecomposedQueryIdWithVersion decomposedQueryIdWithVersion) constNES::Runtime::AbstractQueryManager
getQueryStatistics(DecomposedQueryId decomposedQueryId)NES::Runtime::AbstractQueryManager
getReconfigurationEvent(Network::NetworkSourcePtr networkSource, SharedQueryId sharedQueryId, const ReconfigurationMarker &marker) constNES::Runtime::AbstractQueryManager
getSharedQueryId(DecomposedQueryIdWithVersion decomposedQueryIdWithVersion) constNES::Runtime::AbstractQueryManager
hardwareManagerNES::Runtime::AbstractQueryManagerprotected
inherited0 typedefNES::Runtime::AbstractQueryManager
inherited1 typedefNES::Runtime::AbstractQueryManager
isThreadPoolRunning() constNES::Runtime::AbstractQueryManager
MultiQueueQueryManager(std::shared_ptr< AbstractQueryStatusListener > queryStatusListener, std::vector< BufferManagerPtr > bufferManager, WorkerId nodeEngineId, uint16_t numThreads, HardwareManagerPtr hardwareManager, uint64_t numberOfBuffersPerEpoch, std::vector< uint64_t > workerToCoreMapping={}, uint64_t numberOfQueues=1, uint64_t numberOfThreadsPerQueue=1)NES::Runtime::MultiQueueQueryManagerexplicit
nodeEngineIdNES::Runtime::AbstractQueryManagerprotected
notifyPipelineCompletion(DecomposedQueryId decomposedQueryId, Execution::ExecutablePipelinePtr pipeline, QueryTerminationType terminationType)NES::Runtime::AbstractQueryManager
notifyQueryStatusChange(const Execution::ExecutableQueryPlanPtr &qep, Execution::ExecutableQueryPlanStatus newStatus)NES::Runtime::AbstractQueryManager
notifySinkCompletion(DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, DataSinkPtr sink, QueryTerminationType terminationType)NES::Runtime::AbstractQueryManager
notifySourceCompletion(DataSourcePtr source, QueryTerminationType terminationType)NES::Runtime::AbstractQueryManager
notifySourceFailure(DataSourcePtr source, const std::string errorMessage)NES::Runtime::AbstractQueryManager
notifyTaskFailure(Execution::SuccessorExecutablePipeline pipeline, const std::string &message)NES::Runtime::AbstractQueryManager
numberOfBuffersPerEpochNES::Runtime::AbstractQueryManagerprotected
numThreadsNES::Runtime::AbstractQueryManagerprotected
operator=(const AbstractQueryManager &)=deleteNES::Runtime::AbstractQueryManager
persistentSourcePropertiesNES::Runtime::AbstractQueryManager
postReconfigurationCallback(ReconfigurationMessage &task) overrideNES::Runtime::AbstractQueryManagervirtual
processNextTask(bool running, WorkerContext &workerContext) overrideNES::Runtime::MultiQueueQueryManagervirtual
propagateReconfigurationMarker(const ReconfigurationMarkerPtr &marker, DataSourcePtr source)NES::Runtime::AbstractQueryManager
queryManagerStatusNES::Runtime::AbstractQueryManagerprotected
QueryManagerStatus enum nameNES::Runtime::AbstractQueryManager
queryMutexNES::Runtime::AbstractQueryManagermutableprotected
queryStatusListenerNES::Runtime::AbstractQueryManagerprotected
queryToStatisticsMapNES::Runtime::AbstractQueryManagerprotected
reconfigurationMutexNES::Runtime::AbstractQueryManagermutableprotected
reconfigure(ReconfigurationMessage &, WorkerContext &context) overrideNES::Runtime::AbstractQueryManagervirtual
registerExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &qep) overrideNES::Runtime::MultiQueueQueryManagervirtual
resetQueryStatistics(DecomposedQueryId decomposedQueryId)NES::Runtime::AbstractQueryManager
runningQEPsNES::Runtime::AbstractQueryManagerprotected
virtual_enable_shared_from_this< AbstractQueryManager, false >::shared_from_this()NES::detail::virtual_enable_shared_from_this< AbstractQueryManager, false >inline
NES::Runtime::Reconfigurable::shared_from_this()NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >inline
sourceToQEPMappingNES::Runtime::AbstractQueryManagerprotected
startExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &qep)NES::Runtime::AbstractQueryManager
startNewExecutableQueryPlanAndPropagateMarker(const ReconfigurationMarkerPtr marker, DecomposedQueryIdWithVersion decomposedQueryIdWithVersion)NES::Runtime::AbstractQueryManager
statisticsMutexNES::Runtime::AbstractQueryManagermutableprotected
stopExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &qep, Runtime::QueryTerminationType type=Runtime::QueryTerminationType::HardStop)NES::Runtime::AbstractQueryManager
taskIdCounterNES::Runtime::AbstractQueryManagerprotected
tempCounterTasksCompletedNES::Runtime::AbstractQueryManagerprotected
terminateLoop(WorkerContext &) overrideNES::Runtime::MultiQueueQueryManagerprotectedvirtual
threadPoolNES::Runtime::AbstractQueryManagerprotected
unregisterExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &executableQueryPlan)NES::Runtime::AbstractQueryManager
updateStatistics(const Task &task, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, PipelineId pipeId, WorkerContext &workerContext) overrideNES::Runtime::MultiQueueQueryManagerprotectedvirtual
virtual_enable_shared_from_this< AbstractQueryManager, false >::weak_from_this()NES::detail::virtual_enable_shared_from_this< AbstractQueryManager, false >inline
NES::Runtime::Reconfigurable::weak_from_this()NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >inline
workerToCoreMappingNES::Runtime::AbstractQueryManagerprotected
~AbstractQueryManager() NES_NOEXCEPT(false) overrideNES::Runtime::AbstractQueryManagervirtual
~Reconfigurable() NES_NOEXCEPT(false) override=defaultNES::Runtime::Reconfigurable
virtual_enable_shared_from_this< AbstractQueryManager, false >::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=defaultNES::detail::virtual_enable_shared_from_this< AbstractQueryManager, false >
NES::Runtime::Reconfigurable::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=defaultNES::detail::virtual_enable_shared_from_this< Reconfigurable, false >
~virtual_enable_shared_from_this_base() NES_NOEXCEPT(isNoexceptDestructible)=defaultNES::detail::virtual_enable_shared_from_this_base< isNoexceptDestructible >virtual