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

This is the complete list of members for NES::Statistic::StatisticSink, 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() overrideNES::Statistic::StatisticSinkvirtual
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() overrideNES::Statistic::StatisticSinkvirtual
shared_from_this()NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >inline
sharedQueryIdNES::SinkMediumprotected
shutdown() overrideNES::Statistic::StatisticSinkvirtual
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
StatisticSink(const SinkFormatPtr &sinkFormat, const Runtime::NodeEnginePtr &nodeEngine, uint32_t numOfProducers, SharedQueryId sharedQueryId, DecomposedQueryId decomposedQueryId, DecomposedQueryPlanVersion decomposedQueryVersion, uint64_t numberOfOrigins, StatisticStorePtr statisticStore, StatisticFormatPtr statisticSinkFormat)NES::Statistic::StatisticSink
toString() const overrideNES::Statistic::StatisticSinkvirtual
weak_from_this()NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >inline
writeData(Runtime::TupleBuffer &inputBuffer, Runtime::WorkerContext &workerContext) overrideNES::Statistic::StatisticSinkvirtual
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