NES::CollectTestSink< Type > Member List

This is the complete list of members for NES::CollectTestSink< Type >, including all inherited members.

activeProducers	NES::SinkMedium	protected
CollectTestSink(const SchemaPtr &schema, const Runtime::NodeEnginePtr &nodeEngine, uint32_t numOfProducers=1)	NES::CollectTestSink< Type >	inline
create(const SchemaPtr &schema, const Runtime::NodeEnginePtr &engine, uint32_t numOfProducers=1)	NES::CollectTestSink< Type >	inlinestatic
cv	NES::CollectTestSink< Type >
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
getResult()	NES::CollectTestSink< Type >	inline
getSchemaPtr() const	NES::SinkMedium
getSharedQueryId() const	NES::SinkMedium
getSinkFormat()	NES::SinkMedium
getSinkMediumType() override	NES::CollectTestSink< Type >	inlinevirtual
isForMigration() const	NES::SinkMedium
m	NES::CollectTestSink< Type >	mutable
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
results	NES::CollectTestSink< Type >
running	NES::CollectTestSink< Type >
schemaWritten	NES::SinkMedium	protected
sentBuffer	NES::SinkMedium	protected
sentTuples	NES::SinkMedium	protected
setMigrationFlag()	NES::SinkMedium
setup() override	NES::CollectTestSink< Type >	inlinevirtual
shared_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
sharedQueryId	NES::SinkMedium	protected
shutdown() override	NES::CollectTestSink< Type >	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
toString() const override	NES::CollectTestSink< Type >	inlinevirtual
waitTillCompleted(size_t numberOfRecords)	NES::CollectTestSink< Type >	inline
waitTillCompletedOrTimeout(size_t numberOfRecords, uint64_t timeoutInMilliseconds)	NES::CollectTestSink< Type >	inline
weak_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
writeData(Runtime::TupleBuffer &inputBuffer, Runtime::WorkerContext &) override	NES::CollectTestSink< Type >	inlinevirtual
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