NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
NES::SinkMedium Member List

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

activeProducersNES::SinkMediumprotected
decomposedQueryIdNES::SinkMediumprotected
decomposedQueryVersionNES::SinkMediumprotected
getNumberOfWrittenOutBuffers()NES::SinkMedium
getNumberOfWrittenOutTuples()NES::SinkMedium
getOperatorId() constNES::SinkMedium
getParentPlanId() constNES::SinkMedium
getParentPlanVersion() constNES::SinkMedium
getSchemaPtr() constNES::SinkMedium
getSharedQueryId() constNES::SinkMedium
getSinkFormat()NES::SinkMedium
getSinkMediumType()=0NES::SinkMediumpure virtual
isForMigration() constNES::SinkMedium
migrationNES::SinkMediumprotected
nodeEngineNES::SinkMediumprotected
numberOfOriginsNES::SinkMediumprotected
postReconfigurationCallback(Runtime::ReconfigurationMessage &message) overrideNES::SinkMediumvirtual
reconfigure(Runtime::ReconfigurationMessage &message, Runtime::WorkerContext &context) overrideNES::SinkMediumvirtual
schemaWrittenNES::SinkMediumprotected
sentBufferNES::SinkMediumprotected
sentTuplesNES::SinkMediumprotected
setMigrationFlag()NES::SinkMedium
setup()=0NES::SinkMediumpure virtual
shared_from_this()NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >inline
sharedQueryIdNES::SinkMediumprotected
shutdown()=0NES::SinkMediumpure virtual
sinkFormatNES::SinkMediumprotected
SinkMedium(SinkFormatPtr sinkFormat, Runtime::NodeEnginePtr nodeEngine, uint32_t numOfProducers, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion)NES::SinkMediumexplicit
SinkMedium(SinkFormatPtr sinkFormat, Runtime::NodeEnginePtr nodeEngine, uint32_t numOfProducers, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, uint64_t numberOfOrigins)NES::SinkMediumexplicit
toString() const =0NES::SinkMediumpure virtual
weak_from_this()NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >inline
writeData(Runtime::TupleBuffer &inputBuffer, Runtime::WorkerContext &workerContext)=0NES::SinkMediumpure virtual
writeMutexNES::SinkMediumprotected
~Reconfigurable() NES_NOEXCEPT(false) override=defaultNES::Runtime::Reconfigurable
~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=defaultNES::detail::virtual_enable_shared_from_this< Reconfigurable, false >
~virtual_enable_shared_from_this_base() NES_NOEXCEPT(isNoexceptDestructible)=defaultNES::detail::virtual_enable_shared_from_this_base< isNoexceptDestructible >virtual