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

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

addPredecessor(PredecessorExecutablePipeline pred)NES::Runtime::Execution::PipelineExecutionContextinline
dispatchBuffer(TupleBuffer tupleBuffer)NES::Runtime::Execution::PipelineExecutionContext
emitBuffer(TupleBuffer &tupleBuffer, WorkerContext &)NES::Runtime::Execution::PipelineExecutionContext
getBufferManager() constNES::Runtime::Execution::PipelineExecutionContext
getNextChunkNumber(const SeqNumberOriginId seqNumberOriginId)NES::Runtime::Execution::PipelineExecutionContext
getNumberOfWorkerThreads() constNES::Runtime::Execution::PipelineExecutionContext
getOperatorHandler(std::size_t index)NES::Runtime::Execution::PipelineExecutionContextinline
getOperatorHandlers()NES::Runtime::Execution::PipelineExecutionContext
getPipelineID()NES::Runtime::Execution::PipelineExecutionContextinline
getPredecessors()NES::Runtime::Execution::PipelineExecutionContextinline
isLastChunk(const SeqNumberOriginId seqNumberOriginId, const uint64_t chunkNumber, const bool isLastChunk)NES::Runtime::Execution::PipelineExecutionContext
migrateBuffer(TupleBuffer &buffer, WorkerContextRef workerContext)NES::Runtime::Execution::PipelineExecutionContext
MockedPipelineExecutionContext(Runtime::QueryManagerPtr queryManager, const DataSinkPtr &sink)NES::MockedPipelineExecutionContextinline
MockedPipelineExecutionContext(Runtime::QueryManagerPtr queryManager, DataSinkPtr sink)NES::MockedPipelineExecutionContextinline
PipelineExecutionContext(PipelineId pipelineId, DecomposedQueryId queryId, Runtime::BufferManagerPtr bufferProvider, size_t numberOfWorkerThreads, std::function< void(TupleBuffer &, WorkerContextRef)> &&emitFunctionHandler, std::function< void(TupleBuffer &)> &&emitToQueryManagerFunctionHandler, std::vector< OperatorHandlerPtr > operatorHandlers, std::optional< std::function< void(TupleBuffer &, WorkerContext &)>> emitMigrationHandler=nullptr)NES::Runtime::Execution::PipelineExecutionContextexplicit
removeSequenceState(const SeqNumberOriginId seqNumberOriginId)NES::Runtime::Execution::PipelineExecutionContext
toString() constNES::Runtime::Execution::PipelineExecutionContext