| addExecutableSuccessors(std::vector< Runtime::Execution::SuccessorExecutablePipeline > newPipelines) | NES::DataSource | |
| allocateBuffer() | NES::DataSource | protected |
| bufferManager | NES::DataSource | protected |
| clearPersistedProperties() | NES::DataSource | virtual |
| close() | NES::DataSource | virtual |
| completedPromise | NES::DataSource | protected |
| createOrLoadPersistedProperties() | NES::DataSource | virtual |
| 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::DataSource | explicit |
| DataSource()=delete | NES::DataSource | |
| emitWork(Runtime::TupleBuffer &buffer, bool addBufferMetaData=true) override | NES::DataSource | protectedvirtual |
| executableSuccessors | NES::DataSource | protected |
| fail() | NES::DataSource | virtual |
| futureRetrieved | NES::DataSource | protected |
| gatheringIngestionRate | NES::DataSource | protected |
| gatheringInterval | NES::DataSource | protected |
| gatheringMode | NES::DataSource | protected |
| generatedBuffers | NES::DataSource | protected |
| generatedTuples | NES::DataSource | protected |
| generationFunction | NES::LambdaSource | protected |
| 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::GeneratorSource | inline |
| getExecutableSuccessors() | NES::DataSource | |
| getGatheringInterval() const | NES::DataSource | |
| getGatheringIntervalCount() const | NES::DataSource | |
| getNumberOfGeneratedBuffers() const | NES::DataSource | |
| getNumberOfGeneratedTuples() const | NES::DataSource | |
| getNumBuffersToProcess() const | NES::DataSource | |
| getOperatorId() const | NES::DataSource | |
| getSchema() const | NES::DataSource | |
| getSourceSchemaAsString() | NES::DataSource | |
| getSupportedLayouts() | NES::DataSource | virtual |
| getType() const override | NES::LambdaSource | virtual |
| getVersion() const | NES::DataEmitter | inlinevirtual |
| handleReconfigurationMarker(ReconfigurationMarkerPtr marker) | NES::DataSource | virtual |
| incrementNumberOfConsumerQueries() | NES::DataSource | inline |
| insertReconfigurationMarker(ReconfigurationMarkerPtr) | NES::DataEmitter | inlinevirtual |
| isRunning() const noexcept | NES::DataSource | inline |
| LambdaSource(SchemaPtr schema, Runtime::BufferManagerPtr bufferManager, Runtime::QueryManagerPtr queryManager, uint64_t numbersOfBufferToProduce, uint64_t gatheringValue, std::function< void(NES::Runtime::TupleBuffer &buffer, uint64_t numberOfTuplesToProduce)> &&generationFunction, OperatorId operatorId, OriginId originId, StatisticId statisticId, size_t numSourceLocalBuffers, GatheringMode gatheringMode, uint64_t sourceAffinity, uint64_t taskQueueId, const std::string &physicalSourceName, std::vector< Runtime::Execution::SuccessorExecutablePipeline > successors) | NES::LambdaSource | explicit |
| localBufferManager | NES::DataSource | protected |
| memoryLayout | NES::DataSource | protected |
| numberOfBuffersToProduce | NES::DataSource | protected |
| numberOfConsumerQueries | NES::DataSource | protected |
| numberOfTuplesToProduce | NES::LambdaSource | protected |
| numSourceLocalBuffers | NES::DataSource | protected |
| onEndOfStream(Runtime::QueryTerminationType) | NES::DataEmitter | inlinevirtual |
| onEvent(Runtime::BaseEvent &) override | NES::DataSource | virtual |
| onEvent(Runtime::BaseEvent &event, Runtime::WorkerContextRef workerContext) | NES::DataSource | virtual |
| open() | NES::DataSource | virtual |
| operatorId | NES::DataSource | protected |
| originId | NES::DataSource | protected |
| performSoftStop() | NES::DataSource | virtual |
| persistentSource | NES::DataSource | |
| persistentSourceKey | NES::DataSource | |
| physicalSourceName | NES::DataSource | protected |
| postReconfigurationCallback(ReconfigurationMessage &) | NES::Runtime::Reconfigurable | inlinevirtual |
| queryManager | NES::DataSource | protected |
| receiveData() override | NES::LambdaSource | virtual |
| reconfigure(ReconfigurationMessage &, WorkerContext &) | NES::Runtime::Reconfigurable | inlinevirtual |
| refCounter | NES::DataSource | protected |
| running | NES::DataSource | protected |
| runningRoutine() | NES::DataSource | virtual |
| schema | NES::DataSource | protected |
| setGatheringInterval(std::chrono::milliseconds interval) | NES::DataSource | |
| setOperatorId(OperatorId operatorId) | NES::DataSource | |
| setSourceSharing(bool value) | NES::DataSource | inline |
| shared_from_base() | NES::DataSource | inline |
| 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 |
| sourceAffinity | NES::DataSource | protected |
| sourceSharing | NES::DataSource | protected |
| start() | NES::DataSource | virtual |
| startNewVersion() | NES::DataEmitter | inlinevirtual |
| statisticId | NES::DataSource | protected |
| stop(Runtime::QueryTerminationType graceful) | NES::DataSource | virtual |
| storePersistedProperties() | NES::DataSource | virtual |
| taskQueueId | NES::DataSource | protected |
| toString() const override | NES::LambdaSource | virtual |
| type | NES::DataSource | protected |
| wasGracefullyStopped | NES::DataSource | protected |
| wasStarted | NES::DataSource | protected |
| 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)=default | NES::DataEmitter | virtual |
| ~DataSource() NES_NOEXCEPT(false) override | NES::DataSource | virtual |
| ~Reconfigurable() NES_NOEXCEPT(false) override=default | NES::Runtime::Reconfigurable | |
| NES::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=default | NES::detail::virtual_enable_shared_from_this< Reconfigurable, false > | |
| NES::DataEmitter::~virtual_enable_shared_from_this() NES_NOEXCEPT(isNoexceptDestructible) override=default | NES::detail::virtual_enable_shared_from_this< RuntimeEventListener, false > | |
| ~virtual_enable_shared_from_this_base() NES_NOEXCEPT(isNoexceptDestructible)=default | NES::detail::virtual_enable_shared_from_this_base< isNoexceptDestructible > | virtual |
1.9.1