NES::MonitoringSourceProxy Member List

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

addExecutableSuccessors(std::vector< Runtime::Execution::SuccessorExecutablePipeline > newPipelines)	NES::DataSource
allocateBuffer()	NES::DataSource	protected
bufferManager	NES::DataSource	protected
clearPersistedProperties()	NES::DataSource	virtual
close()	NES::DataSource	virtual
completedPromise	NES::DataSource	protected
createOrLoadPersistedProperties()	NES::DataSource	virtual
DataSource(SchemaPtr schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, const std::string &physicalSourceName, bool persistentSource, std::vector< Runtime::Execution::SuccessorExecutablePipeline > executableSuccessors=std::vector< Runtime::Execution::SuccessorExecutablePipeline >(), uint64_t sourceAffinity=std::numeric_limits< uint64_t >::max(), uint64_t taskQueueId=0)	NES::DataSource	explicit
DataSource()=delete	NES::DataSource
DEFAULT_WAIT_TIME	NES::MonitoringSource	static
emitWork(Runtime::TupleBuffer &buffer, bool addBufferMetaData=true) override	NES::DataSource	protectedvirtual
executableSuccessors	NES::DataSource	protected
fail()	NES::DataSource	virtual
futureRetrieved	NES::DataSource	protected
gatheringIngestionRate	NES::DataSource	protected
gatheringInterval	NES::DataSource	protected
gatheringMode	NES::DataSource	protected
generatedBuffers	NES::DataSource	protected
generatedTuples	NES::DataSource	protected
getCollectorType()	NES::MonitoringSource
getExecutableSuccessors()	NES::DataSource
getGatheringInterval() const	NES::DataSource
getGatheringIntervalCount() const	NES::DataSource
getNumberOfGeneratedBuffers() const	NES::DataSource
getNumberOfGeneratedTuples() const	NES::DataSource
getNumBuffersToProcess() const	NES::DataSource
getOperatorId() const	NES::DataSource
getSchema() const	NES::DataSource
getSourceSchemaAsString()	NES::DataSource
getSupportedLayouts()	NES::DataSource	virtual
getType() const override	NES::MonitoringSource	virtual
getVersion() const	NES::DataEmitter	inlinevirtual
getWaitTime() const	NES::MonitoringSource
handleReconfigurationMarker(ReconfigurationMarkerPtr marker)	NES::DataSource	virtual
incrementNumberOfConsumerQueries()	NES::DataSource	inline
insertReconfigurationMarker(ReconfigurationMarkerPtr)	NES::DataEmitter	inlinevirtual
isRunning() const noexcept	NES::DataSource	inline
localBufferManager	NES::DataSource	protected
memoryLayout	NES::DataSource	protected
MonitoringSource(Monitoring::MetricCollectorPtr metricCollector, std::chrono::milliseconds waitTime, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, std::vector< Runtime::Execution::SuccessorExecutablePipeline > successors={})	NES::MonitoringSource
MonitoringSourceProxy(const Monitoring::MetricCollectorPtr &metricCollector, std::chrono::milliseconds waitTime, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, OperatorId operatorId, size_t numSourceLocalBuffers, std::vector< Runtime::Execution::SuccessorExecutablePipeline > successors={})	NES::MonitoringSourceProxy	inline
numberOfBuffersToProduce	NES::DataSource	protected
numberOfConsumerQueries	NES::DataSource	protected
numSourceLocalBuffers	NES::DataSource	protected
onEndOfStream(Runtime::QueryTerminationType)	NES::DataEmitter	inlinevirtual
onEvent(Runtime::BaseEvent &) override	NES::DataSource	virtual
onEvent(Runtime::BaseEvent &event, Runtime::WorkerContextRef workerContext)	NES::DataSource	virtual
open()	NES::DataSource	virtual
operatorId	NES::DataSource	protected
originId	NES::DataSource	protected
performSoftStop()	NES::DataSource	virtual
persistentSource	NES::DataSource
persistentSourceKey	NES::DataSource
physicalSourceName	NES::DataSource	protected
postReconfigurationCallback(ReconfigurationMessage &)	NES::Runtime::Reconfigurable	inlinevirtual
queryManager	NES::DataSource	protected
receiveData() override	NES::MonitoringSource	virtual
reconfigure(ReconfigurationMessage &, WorkerContext &)	NES::Runtime::Reconfigurable	inlinevirtual
refCounter	NES::DataSource	protected
running	NES::DataSource	protected
runningRoutine()	NES::DataSource	virtual
schema	NES::DataSource	protected
setGatheringInterval(std::chrono::milliseconds interval)	NES::DataSource
setOperatorId(OperatorId operatorId)	NES::DataSource
setSourceSharing(bool value)	NES::DataSource	inline
shared_from_base()	NES::DataSource	inline
NES::shared_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
NES::DataEmitter::shared_from_this()	NES::detail::virtual_enable_shared_from_this< RuntimeEventListener, false >	inline
sourceAffinity	NES::DataSource	protected
sourceSharing	NES::DataSource	protected
start()	NES::DataSource	virtual
startNewVersion()	NES::DataEmitter	inlinevirtual
statisticId	NES::DataSource	protected
stop(Runtime::QueryTerminationType graceful)	NES::DataSource	virtual
storePersistedProperties()	NES::DataSource	virtual
taskQueueId	NES::DataSource	protected
toString() const override	NES::MonitoringSource	virtual
type	NES::DataSource	protected
wasGracefullyStopped	NES::DataSource	protected
wasStarted	NES::DataSource	protected
NES::weak_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
NES::DataEmitter::weak_from_this()	NES::detail::virtual_enable_shared_from_this< RuntimeEventListener, false >	inline
~DataEmitter() NES_NOEXCEPT(false)=default	NES::DataEmitter	virtual
~DataSource() NES_NOEXCEPT(false) override	NES::DataSource	virtual
~Reconfigurable() NES_NOEXCEPT(false) override=default	NES::Runtime::Reconfigurable
NES::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=default	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >
NES::DataEmitter::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=default	NES::detail::virtual_enable_shared_from_this< RuntimeEventListener, false >
~virtual_enable_shared_from_this_base() NES_NOEXCEPT(isNoexceptDestructible)=default	NES::detail::virtual_enable_shared_from_this_base< isNoexceptDestructible >	virtual