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

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

addExecutableSuccessors(std::vector< Runtime::Execution::SuccessorExecutablePipeline > newPipelines)NES::DataSource
allocateBuffer()NES::DataSourceprotected
bufferManagerNES::DataSourceprotected
clearPersistedProperties()NES::DataSourcevirtual
close()NES::DataSourcevirtual
completedPromiseNES::DataSourceprotected
createOrLoadPersistedProperties()NES::DataSourcevirtual
DataSource(SchemaPtr schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, const std::string &physicalSourceName, bool persistentSource, std::vector< Runtime::Execution::SuccessorExecutablePipeline > executableSuccessors=std::vector< Runtime::Execution::SuccessorExecutablePipeline >(), uint64_t sourceAffinity=std::numeric_limits< uint64_t >::max(), uint64_t taskQueueId=0)NES::DataSourceexplicit
DataSource()=deleteNES::DataSource
emitWork(Runtime::TupleBuffer &buffer, bool addBufferMetaData=true) overrideNES::DataSourceprotectedvirtual
executableSuccessorsNES::DataSourceprotected
fail()NES::DataSourcevirtual
futureRetrievedNES::DataSourceprotected
gatheringIngestionRateNES::DataSourceprotected
gatheringIntervalNES::DataSourceprotected
gatheringModeNES::DataSourceprotected
generatedBuffersNES::DataSourceprotected
generatedTuplesNES::DataSourceprotected
GeneratorSource(SchemaPtr schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, uint64_t numberOfBufferToProduce, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, std::vector< Runtime::Execution::SuccessorExecutablePipeline > successors, const std::string &physicalSourceName=std::string("defaultPhysicalStreamName"))NES::GeneratorSourceinline
getExecutableSuccessors()NES::DataSource
getGatheringInterval() constNES::DataSource
getGatheringIntervalCount() constNES::DataSource
getNumberOfGeneratedBuffers() constNES::DataSource
getNumberOfGeneratedTuples() constNES::DataSource
getNumBuffersToProcess() constNES::DataSource
getOperatorId() constNES::DataSource
getSchema() constNES::DataSource
getSourceSchemaAsString()NES::DataSource
getSupportedLayouts()NES::DataSourcevirtual
getType() const overrideNES::Experimental::StaticDataSourcevirtual
getVersion() constNES::DataEmitterinlinevirtual
handleReconfigurationMarker(ReconfigurationMarkerPtr marker)NES::DataSourcevirtual
incrementNumberOfConsumerQueries()NES::DataSourceinline
insertReconfigurationMarker(ReconfigurationMarkerPtr)NES::DataEmitterinlinevirtual
isRunning() const noexceptNES::DataSourceinline
localBufferManagerNES::DataSourceprotected
memoryLayoutNES::DataSourceprotected
numberOfBuffersToProduceNES::DataSourceprotected
numberOfConsumerQueriesNES::DataSourceprotected
numSourceLocalBuffersNES::DataSourceprotected
onEndOfStream(Runtime::QueryTerminationType)NES::DataEmitterinlinevirtual
onEvent(Runtime::BaseEvent &) finalNES::Experimental::StaticDataSourcevirtual
NES::GeneratorSource::onEvent(Runtime::BaseEvent &event, Runtime::WorkerContextRef workerContext)NES::DataSourcevirtual
open() overrideNES::Experimental::StaticDataSourcevirtual
operatorIdNES::DataSourceprotected
originIdNES::DataSourceprotected
performSoftStop()NES::DataSourcevirtual
persistentSourceNES::DataSource
persistentSourceKeyNES::DataSource
physicalSourceNameNES::DataSourceprotected
postReconfigurationCallback(ReconfigurationMessage &)NES::Runtime::Reconfigurableinlinevirtual
preloadBuffers()NES::Experimental::StaticDataSource
queryManagerNES::DataSourceprotected
receiveData() overrideNES::Experimental::StaticDataSourcevirtual
reconfigure(ReconfigurationMessage &, WorkerContext &)NES::Runtime::Reconfigurableinlinevirtual
recyclePooledBuffer(::NES::Runtime::detail::MemorySegment *) overrideNES::Experimental::StaticDataSourceinlinevirtual
NES::Runtime::BufferRecycler::recyclePooledBuffer(detail::MemorySegment *buffer)=0NES::Runtime::BufferRecyclerpure virtual
recycleUnpooledBuffer(::NES::Runtime::detail::MemorySegment *) overrideNES::Experimental::StaticDataSourceinlinevirtual
NES::Runtime::BufferRecycler::recycleUnpooledBuffer(detail::MemorySegment *buffer)=0NES::Runtime::BufferRecyclerpure virtual
refCounterNES::DataSourceprotected
runningNES::DataSourceprotected
runningRoutine()NES::DataSourcevirtual
schemaNES::DataSourceprotected
setGatheringInterval(std::chrono::milliseconds interval)NES::DataSource
setOperatorId(OperatorId operatorId)NES::DataSource
setSourceSharing(bool value)NES::DataSourceinline
shared_from_base()NES::DataSourceinline
NES::shared_from_this()NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >inline
NES::DataEmitter::shared_from_this()NES::detail::virtual_enable_shared_from_this< RuntimeEventListener, false >inline
sourceAffinityNES::DataSourceprotected
sourceSharingNES::DataSourceprotected
start() finalNES::Experimental::StaticDataSourcevirtual
startNewVersion()NES::DataEmitterinlinevirtual
startStaticDataSourceManually()NES::Experimental::StaticDataSource
StaticDataSource(SchemaPtr schema, std::string pathTableFile, const bool lateStart, ::NES::Runtime::BufferManagerPtr bufferManager, ::NES::Runtime::QueryManagerPtr queryManager, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, const std::string &physicalSourceName, std::vector<::NES::Runtime::Execution::SuccessorExecutablePipeline > successors)NES::Experimental::StaticDataSourceexplicit
statisticIdNES::DataSourceprotected
stop(Runtime::QueryTerminationType graceful)NES::DataSourcevirtual
storePersistedProperties()NES::DataSourcevirtual
taskQueueIdNES::DataSourceprotected
toString() const overrideNES::Experimental::StaticDataSourcevirtual
typeNES::DataSourceprotected
wasGracefullyStoppedNES::DataSourceprotected
wasStartedNES::DataSourceprotected
NES::weak_from_this()NES::detail::virtual_enable_shared_from_this< Reconfigurable, false >inline
NES::DataEmitter::weak_from_this()NES::detail::virtual_enable_shared_from_this< RuntimeEventListener, false >inline
~DataEmitter() NES_NOEXCEPT(false)=defaultNES::DataEmittervirtual
~DataSource() NES_NOEXCEPT(false) overrideNES::DataSourcevirtual
~Reconfigurable() NES_NOEXCEPT(false) override=defaultNES::Runtime::Reconfigurable
NES::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=defaultNES::detail::virtual_enable_shared_from_this< Reconfigurable, false >
NES::DataEmitter::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=defaultNES::detail::virtual_enable_shared_from_this< RuntimeEventListener, false >
~virtual_enable_shared_from_this_base() NES_NOEXCEPT(isNoexceptDestructible)=defaultNES::detail::virtual_enable_shared_from_this_base< isNoexceptDestructible >virtual