NES::TestSink Member List

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

activeProducers	NES::SinkMedium	protected
cleanupBuffers()	NES::TestSink
completed	NES::TestSink
create(uint64_t expectedTuples, const SchemaPtr &schema, const Runtime::NodeEnginePtr &engine, uint32_t numOfProducers=1)	NES::TestSink	static
decomposedQueryId	NES::SinkMedium	protected
decomposedQueryVersion	NES::SinkMedium	protected
get(uint64_t index)	NES::TestSink
getNumberOfResultBuffers()	NES::TestSink
getNumberOfWrittenOutBuffers()	NES::SinkMedium
getNumberOfWrittenOutTuples()	NES::SinkMedium
getOperatorId() const	NES::SinkMedium
getParentPlanId() const	NES::SinkMedium
getParentPlanVersion() const	NES::SinkMedium
getResultBuffer(uint64_t index)	NES::TestSink
getResultBuffers()	NES::TestSink
getSchemaPtr() const	NES::SinkMedium
getSharedQueryId() const	NES::SinkMedium
getSinkFormat()	NES::SinkMedium
getSinkMediumType() override	NES::TestSink	virtual
isForMigration() const	NES::SinkMedium
m	NES::TestSink	mutable
memoryLayout	NES::TestSink
migration	NES::SinkMedium	protected
nodeEngine	NES::SinkMedium	protected
numberOfOrigins	NES::SinkMedium	protected
numOfExpectedTuples	NES::TestSink
postReconfigurationCallback(Runtime::ReconfigurationMessage &message) override	NES::SinkMedium	virtual
reconfigure(Runtime::ReconfigurationMessage &message, Runtime::WorkerContext &context) override	NES::SinkMedium	virtual
resultBuffers	NES::TestSink
schemaWritten	NES::SinkMedium	protected
sentBuffer	NES::SinkMedium	protected
sentTuples	NES::SinkMedium	protected
setMigrationFlag()	NES::SinkMedium
setup() override	NES::TestSink	virtual
shared_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
sharedQueryId	NES::SinkMedium	protected
shutdown() override	NES::TestSink	virtual
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(uint64_t expectedTuples, const SchemaPtr &schema, const Runtime::NodeEnginePtr &nodeEngine, uint32_t numOfProducers=1)	NES::TestSink
toString() const override	NES::TestSink	virtual
waitTillCompleted()	NES::TestSink
waitTillCompletedOrTimeout(uint64_t timeoutInMilliseconds)	NES::TestSink
weak_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
writeData(Runtime::TupleBuffer &inputBuffer, Runtime::WorkerContext &) override	NES::TestSink	virtual
writeMutex	NES::SinkMedium	protected
~Reconfigurable() NES_NOEXCEPT(false) override=default	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