NES::Network::NetworkSource Member List

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

addExecutableSuccessors(std::vector< Runtime::Execution::SuccessorExecutablePipeline > newPipelines)	NES::DataSource
allocateBuffer()	NES::DataSource	protected
bind()	NES::Network::NetworkSource
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
emitWork(Runtime::TupleBuffer &buffer, bool addBufferMetaData=true) override	NES::DataSource	protectedvirtual
executableSuccessors	NES::DataSource	protected
fail() final	NES::Network::NetworkSource	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
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::Network::NetworkSource	virtual
getUniqueId() const	NES::Network::NetworkSource
getVersion() const override	NES::Network::NetworkSource	virtual
handleReconfigurationMarker(ReconfigurationMarkerPtr marker) override	NES::Network::NetworkSource	virtual
incrementNumberOfConsumerQueries()	NES::DataSource	inline
insertReconfigurationMarker(ReconfigurationMarkerPtr marker) override	NES::Network::NetworkSource	virtual
isRunning() const noexcept	NES::DataSource	inline
localBufferManager	NES::DataSource	protected
memoryLayout	NES::DataSource	protected
NetworkSource(SchemaPtr schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, NetworkManagerPtr networkManager, NesPartition nesPartition, NodeLocation sinkLocation, size_t numSourceLocalBuffers, std::chrono::milliseconds waitTime, uint8_t retryTimes, std::vector< Runtime::Execution::SuccessorExecutablePipeline > successors, DecomposedQueryPlanVersion version, OperatorId uniqueNetworkSourceIdentifier, const std::string &physicalSourceName="defaultPhysicalSourceName")	NES::Network::NetworkSource
numberOfBuffersToProduce	NES::DataSource	protected
numberOfConsumerQueries	NES::DataSource	protected
numSourceLocalBuffers	NES::DataSource	protected
onEndOfStream(Runtime::QueryTerminationType terminationType) override	NES::Network::NetworkSource	virtual
onEvent(Runtime::BaseEvent &event) override	NES::Network::NetworkSource	virtual
onEvent(Runtime::BaseEvent &event, Runtime::WorkerContextRef workerContext) override	NES::Network::NetworkSource	virtual
open()	NES::DataSource	virtual
operator<(const NetworkSource &lhs, const NetworkSource &rhs)	NES::Network::NetworkSource	friend
operatorId	NES::DataSource	protected
originId	NES::DataSource	protected
performSoftStop()	NES::DataSource	virtual
persistentSource	NES::DataSource
persistentSourceKey	NES::DataSource
physicalSourceName	NES::DataSource	protected
postReconfigurationCallback(Runtime::ReconfigurationMessage &message) override	NES::Network::NetworkSource	virtual
queryManager	NES::DataSource	protected
receiveData() override	NES::Network::NetworkSource	virtual
reconfigure(Runtime::ReconfigurationMessage &message, Runtime::WorkerContext &context) override	NES::Network::NetworkSource	virtual
refCounter	NES::DataSource	protected
running	NES::DataSource	protected
runningRoutine(const Runtime::BufferManagerPtr &, const Runtime::QueryManagerPtr &)	NES::Network::NetworkSource	static
NES::DataSource::runningRoutine()	NES::DataSource	virtual
scheduleNewDescriptor(const NetworkSourceDescriptor &networkSourceDescriptor)	NES::Network::NetworkSource
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() final	NES::Network::NetworkSource	virtual
startNewVersion() override	NES::Network::NetworkSource	virtual
statisticId	NES::DataSource	protected
stop(Runtime::QueryTerminationType=Runtime::QueryTerminationType::Graceful) final	NES::Network::NetworkSource	virtual
storePersistedProperties()	NES::DataSource	virtual
taskQueueId	NES::DataSource	protected
toString() const override	NES::Network::NetworkSource	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