NES::RawBufferSink Member List

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

activeProducers	NES::SinkMedium	protected
append	NES::RawBufferSink	protected
decomposedQueryId	NES::SinkMedium	protected
decomposedQueryVersion	NES::SinkMedium	protected
filePath	NES::RawBufferSink	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::RawBufferSink	virtual
isForMigration() const	NES::SinkMedium
isOpen	NES::RawBufferSink	protected
migration	NES::SinkMedium	protected
nodeEngine	NES::SinkMedium	protected
numberOfOrigins	NES::SinkMedium	protected
outputFile	NES::RawBufferSink	protected
postReconfigurationCallback(Runtime::ReconfigurationMessage &message) override	NES::SinkMedium	virtual
RawBufferSink(Runtime::NodeEnginePtr nodeEngine, uint32_t numOfProducers, const std::string &filePath, bool append, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, uint64_t numberOfOrigins=1)	NES::RawBufferSink	explicit
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::RawBufferSink	virtual
shared_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
sharedQueryId	NES::SinkMedium	protected
shutdown() override	NES::RawBufferSink	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
toString() const override	NES::RawBufferSink	virtual
weak_from_this()	NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >	inline
writeData(Runtime::TupleBuffer &inputBuffer, Runtime::WorkerContextRef) override	NES::RawBufferSink
NES::SinkMedium::writeData(Runtime::TupleBuffer &inputBuffer, Runtime::WorkerContext &workerContext)=0	NES::SinkMedium	pure virtual
writeMutex	NES::SinkMedium	protected
~RawBufferSink() override	NES::RawBufferSink
~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