NES::TCPSource Member List

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

addExecutableSuccessors(std::vector< Runtime::Execution::SuccessorExecutablePipeline > newPipelines)	NES::DataSource
allocateBuffer()	NES::DataSource	protected
bufferManager	NES::DataSource	protected
clearPersistedProperties() override	NES::TCPSource	virtual
close() override	NES::TCPSource	virtual
close() override	NES::TCPSource	virtual
completedPromise	NES::DataSource	protected
createOrLoadPersistedProperties() override	NES::TCPSource	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()	NES::DataSource	virtual
fillBuffer(Runtime::MemoryLayouts::TestTupleBuffer &)	NES::TCPSource
fillBuffer(Runtime::MemoryLayouts::TestTupleBuffer &)	NES::TCPSource
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
getSourceConfig() const	NES::TCPSource
getSourceConfig() const	NES::TCPSource
getSourceSchemaAsString()	NES::DataSource
getSupportedLayouts()	NES::DataSource	virtual
getType() const override	NES::TCPSource	virtual
getType() const override	NES::TCPSource	virtual
getVersion() const	NES::DataEmitter	inlinevirtual
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
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() override	NES::TCPSource	virtual
open() override	NES::TCPSource	virtual
operatorId	NES::DataSource	protected
originId	NES::DataSource	protected
performSoftStop()	NES::DataSource	virtual
persistentSource	NES::DataSource
persistentSourceKey	NES::DataSource
physicalSourceName	NES::DataSource	protected
popGivenNumberOfValues(uint64_t numberOfValuesToPop, bool popTextDivider)	NES::TCPSource
postReconfigurationCallback(ReconfigurationMessage &)	NES::Runtime::Reconfigurable	inlinevirtual
queryManager	NES::DataSource	protected
receiveData() override	NES::TCPSource	virtual
receiveData() override	NES::TCPSource	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
sizeUntilSearchToken(char token)	NES::TCPSource
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() override	NES::TCPSource	virtual
taskQueueId	NES::DataSource	protected
TCPSource(SchemaPtr schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, const TCPSourceTypePtr &tcpSourceType, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, const std::string &physicalSourceName, std::vector< Runtime::Execution::SuccessorExecutablePipeline > executableSuccessors)	NES::TCPSource	explicit
TCPSource(SchemaPtr schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, TCPSourceTypePtr tcpSourceType, OperatorId operatorId, OriginId originId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, const std::string &physicalSourceName, std::vector< Runtime::Execution::SuccessorExecutablePipeline > executableSuccessors)	NES::TCPSource	explicit
toString() const override	NES::TCPSource	virtual
toString() const override	NES::TCPSource	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