NES::Runtime::AbstractQueryManager Member List

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

AbstractQueryManager()=delete	NES::Runtime::AbstractQueryManager
AbstractQueryManager(const AbstractQueryManager &)=delete	NES::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::AbstractQueryManager	explicit
addEndOfStream(DataSourcePtr source, Runtime::QueryTerminationType graceful=Runtime::QueryTerminationType::Graceful)	NES::Runtime::AbstractQueryManager
addFailureEndOfStream(DataSourcePtr source)	NES::Runtime::AbstractQueryManager	protected
addHardEndOfStream(DataSourcePtr source)	NES::Runtime::AbstractQueryManager	protected
addReconfigurationMessage(SharedQueryId sharedQueryId, DecomposedQueryId queryExecutionPlanId, DecomposedQueryPlanVersion queryExecutionPlanVersion, const ReconfigurationMessage &reconfigurationMessage, bool blocking=false)=0	NES::Runtime::AbstractQueryManager	pure virtual
addSoftEndOfStream(DataSourcePtr source)	NES::Runtime::AbstractQueryManager	protected
addWorkForNextPipeline(TupleBuffer &buffer, Execution::SuccessorExecutablePipeline executable, uint32_t queueId=0)=0	NES::Runtime::AbstractQueryManager	pure virtual
asyncTaskExecutor	NES::Runtime::AbstractQueryManager	protected
bufferManagers	NES::Runtime::AbstractQueryManager	protected
canTriggerEndOfStream(DataSourcePtr source, Runtime::QueryTerminationType)	NES::Runtime::AbstractQueryManager
completedWork(Task &task, WorkerContext &workerContext)	NES::Runtime::AbstractQueryManager	protected
decomposeQueryToSourceIdMapping	NES::Runtime::AbstractQueryManager	protected
destroy()	NES::Runtime::AbstractQueryManager	virtual
failExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &qep)	NES::Runtime::AbstractQueryManager
getBufferManager()	NES::Runtime::AbstractQueryManager	inline
getCurrentTaskSum()	NES::Runtime::AbstractQueryManager
getExecutablePlanIdsForSource(DataSourcePtr source) const	NES::Runtime::AbstractQueryManager
getNextTaskId()	NES::Runtime::AbstractQueryManager	protected
getNodeId() const	NES::Runtime::AbstractQueryManager
getNumberOfBuffersPerEpoch() const	NES::Runtime::AbstractQueryManager
getNumberOfTasksInWorkerQueues() const =0	NES::Runtime::AbstractQueryManager	pure virtual
getNumberOfWorkerThreads()	NES::Runtime::AbstractQueryManager
getQepStatus(DecomposedQueryIdWithVersion decomposedQueryIdWithVersion)	NES::Runtime::AbstractQueryManager
getQueryExecutionPlan(DecomposedQueryIdWithVersion decomposedQueryIdWithVersion) const	NES::Runtime::AbstractQueryManager
getQueryStatistics(DecomposedQueryId decomposedQueryId)	NES::Runtime::AbstractQueryManager
getReconfigurationEvent(Network::NetworkSourcePtr networkSource, SharedQueryId sharedQueryId, const ReconfigurationMarker &marker) const	NES::Runtime::AbstractQueryManager
getSharedQueryId(DecomposedQueryIdWithVersion decomposedQueryIdWithVersion) const	NES::Runtime::AbstractQueryManager
hardwareManager	NES::Runtime::AbstractQueryManager	protected
inherited0 typedef	NES::Runtime::AbstractQueryManager
inherited1 typedef	NES::Runtime::AbstractQueryManager
isThreadPoolRunning() const	NES::Runtime::AbstractQueryManager
NodeEngine class	NES::Runtime::AbstractQueryManager	friend
nodeEngineId	NES::Runtime::AbstractQueryManager	protected
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
numberOfBuffersPerEpoch	NES::Runtime::AbstractQueryManager	protected
numThreads	NES::Runtime::AbstractQueryManager	protected
operator=(const AbstractQueryManager &)=delete	NES::Runtime::AbstractQueryManager
persistentSourceProperties	NES::Runtime::AbstractQueryManager
poisonWorkers()=0	NES::Runtime::AbstractQueryManager	pure virtual
postReconfigurationCallback(ReconfigurationMessage &task) override	NES::Runtime::AbstractQueryManager	virtual
processNextTask(bool running, WorkerContext &workerContext)=0	NES::Runtime::AbstractQueryManager	pure virtual
propagateReconfigurationMarker(const ReconfigurationMarkerPtr &marker, DataSourcePtr source)	NES::Runtime::AbstractQueryManager
queryManagerStatus	NES::Runtime::AbstractQueryManager	protected
QueryManagerStatus enum name	NES::Runtime::AbstractQueryManager
queryMutex	NES::Runtime::AbstractQueryManager	mutableprotected
queryStatusListener	NES::Runtime::AbstractQueryManager	protected
queryToStatisticsMap	NES::Runtime::AbstractQueryManager	protected
reconfigurationMutex	NES::Runtime::AbstractQueryManager	mutableprotected
reconfigure(ReconfigurationMessage &, WorkerContext &context) override	NES::Runtime::AbstractQueryManager	virtual
registerExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &executableQueryPlan)	NES::Runtime::AbstractQueryManager	virtual
resetQueryStatistics(DecomposedQueryId decomposedQueryId)	NES::Runtime::AbstractQueryManager
runningQEPs	NES::Runtime::AbstractQueryManager	protected
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
sourceToQEPMapping	NES::Runtime::AbstractQueryManager	protected
startExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &qep)	NES::Runtime::AbstractQueryManager
startNewExecutableQueryPlanAndPropagateMarker(const ReconfigurationMarkerPtr marker, DecomposedQueryIdWithVersion decomposedQueryIdWithVersion)	NES::Runtime::AbstractQueryManager
statisticsMutex	NES::Runtime::AbstractQueryManager	mutableprotected
stopExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &qep, Runtime::QueryTerminationType type=Runtime::QueryTerminationType::HardStop)	NES::Runtime::AbstractQueryManager
taskIdCounter	NES::Runtime::AbstractQueryManager	protected
tempCounterTasksCompleted	NES::Runtime::AbstractQueryManager	protected
terminateLoop(WorkerContext &)=0	NES::Runtime::AbstractQueryManager	protectedpure virtual
ThreadPool class	NES::Runtime::AbstractQueryManager	friend
threadPool	NES::Runtime::AbstractQueryManager	protected
unregisterExecutableQueryPlan(const Execution::ExecutableQueryPlanPtr &executableQueryPlan)	NES::Runtime::AbstractQueryManager
updateStatistics(const Task &task, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, PipelineId pipelineId, WorkerContext &workerContext)	NES::Runtime::AbstractQueryManager	protectedvirtual
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
workerToCoreMapping	NES::Runtime::AbstractQueryManager	protected
~AbstractQueryManager() NES_NOEXCEPT(false) override	NES::Runtime::AbstractQueryManager	virtual
~Reconfigurable() NES_NOEXCEPT(false) override=default	NES::Runtime::Reconfigurable
virtual_enable_shared_from_this< AbstractQueryManager, false >::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=default	NES::detail::virtual_enable_shared_from_this< AbstractQueryManager, false >
NES::Runtime::Reconfigurable::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=default	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >
~virtual_enable_shared_from_this_base() NES_NOEXCEPT(isNoexceptDestructible)=default	NES::detail::virtual_enable_shared_from_this_base< isNoexceptDestructible >	virtual