NES::FileSink Member List

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

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