NES::Network::TestSink Member List

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

activeProducers	NES::SinkMedium	protected
completed	NES::Network::TestSink
decomposedQueryId	NES::SinkMedium	protected
decomposedQueryVersion	NES::SinkMedium	protected
getNumberOfWrittenOutBuffers()	NES::SinkMedium
getNumberOfWrittenOutTuples()	NES::SinkMedium
getOperatorId() const	NES::SinkMedium
getParentPlanId() const	NES::SinkMedium
getParentPlanVersion() const	NES::SinkMedium
getSchemaPtr() const	NES::SinkMedium
getSharedQueryId() const	NES::SinkMedium
getSinkFormat()	NES::SinkMedium
getSinkMediumType() override	NES::Network::TestSink	inlinevirtual
getSinkMediumType() override	NES::Network::TestSink	inlinevirtual
isForMigration() const	NES::SinkMedium
m	NES::Network::TestSink
migration	NES::SinkMedium	protected
nodeEngine	NES::SinkMedium	protected
numberOfOrigins	NES::SinkMedium	protected
postReconfigurationCallback(Runtime::ReconfigurationMessage &message) override	NES::SinkMedium	virtual
reconfigure(Runtime::ReconfigurationMessage &message, Runtime::WorkerContext &context) override	NES::SinkMedium	virtual
schemaWritten	NES::SinkMedium	protected
sentBuffer	NES::SinkMedium	protected
sentTuples	NES::SinkMedium	protected
setMigrationFlag()	NES::SinkMedium
setup() override	NES::Network::TestSink	inlinevirtual
setup() override	NES::Network::TestSink	inlinevirtual
shared_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
sharedQueryId	NES::SinkMedium	protected
shutdown() override	NES::Network::TestSink	inlinevirtual
shutdown() override	NES::Network::TestSink	inlinevirtual
sinkFormat	NES::SinkMedium	protected
SinkMedium(SinkFormatPtr sinkFormat, Runtime::NodeEnginePtr nodeEngine, uint32_t numOfProducers, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion)	NES::SinkMedium	explicit
SinkMedium(SinkFormatPtr sinkFormat, Runtime::NodeEnginePtr nodeEngine, uint32_t numOfProducers, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, uint64_t numberOfOrigins)	NES::SinkMedium	explicit
TestSink(const SchemaPtr &schema, Runtime::NodeEnginePtr nodeEngine, const Runtime::BufferManagerPtr &bufferManager, uint32_t numOfProducers=1, SharedQueryId sharedQueryId=INVALID_SHARED_QUERY_ID, DecomposedQueryId decomposedQueryId=INVALID_DECOMPOSED_QUERY_PLAN_ID, DecomposedQueryPlanVersion decomposedQueryVersion=INVALID_DECOMPOSED_QUERY_PLAN_VERSION)	NES::Network::TestSink	inline
TestSink(const SchemaPtr &schema, Runtime::NodeEnginePtr nodeEngine, const Runtime::BufferManagerPtr &bufferManager, uint32_t numOfProducers=1, SharedQueryId sharedQueryId=INVALID_SHARED_QUERY_ID, DecomposedQueryId decomposedQueryId=INVALID_DECOMPOSED_QUERY_PLAN_ID, DecomposedQueryPlanVersion decomposedQueryVersion=INVALID_DECOMPOSED_QUERY_PLAN_VERSION)	NES::Network::TestSink	inline
toString() const override	NES::Network::TestSink	inlinevirtual
toString() const override	NES::Network::TestSink	inlinevirtual
weak_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
writeData(Runtime::TupleBuffer &input_buffer, Runtime::WorkerContextRef) override	NES::Network::TestSink	inline
writeData(Runtime::TupleBuffer &input_buffer, Runtime::WorkerContextRef) override	NES::Network::TestSink	inline
NES::SinkMedium::writeData(Runtime::TupleBuffer &inputBuffer, Runtime::WorkerContext &workerContext)=0	NES::SinkMedium	pure virtual
writeMutex	NES::SinkMedium	protected
~Reconfigurable() NES_NOEXCEPT(false) override=default	NES::Runtime::Reconfigurable
~TestSink() override=default	NES::Network::TestSink
~TestSink() override=default	NES::Network::TestSink
~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