|
| | MockedPipelineExecutionContext (Runtime::QueryManagerPtr queryManager, const DataSinkPtr &sink) |
| |
| | MockedPipelineExecutionContext (Runtime::QueryManagerPtr queryManager, DataSinkPtr sink) |
| |
| | 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) |
| | The PipelineExecutionContext is passed to the compiled pipeline and enables interaction with the NES Runtime. More...
|
| |
| void | emitBuffer (TupleBuffer &tupleBuffer, WorkerContext &) |
| | Emits a output tuple buffer to the Runtime. Internally we call the emit function which is a callback to the correct handler. More...
|
| |
| void | dispatchBuffer (TupleBuffer tupleBuffer) |
| | Dispatch a buffer as a new task to the query manager. Consequently, a new task is created and the call returns directly. More...
|
| |
| void | migrateBuffer (TupleBuffer &buffer, WorkerContextRef workerContext) |
| | Emits a output tuple to migration pipeline. More...
|
| |
| std::vector< OperatorHandlerPtr > | getOperatorHandlers () |
| | Retrieve all registered operator handlers. More...
|
| |
| template<class OperatorHandlerType > |
| auto | getOperatorHandler (std::size_t index) |
| | Retrieves a Operator Handler at a specific index and cast its to an OperatorHandlerType. More...
|
| |
| std::vector< PredecessorExecutablePipeline > & | getPredecessors () |
| |
| void | addPredecessor (PredecessorExecutablePipeline pred) |
| |
| std::string | toString () const |
| |
| PipelineId | getPipelineID () |
| |
| uint64_t | getNumberOfWorkerThreads () const |
| | Returns the number of worker threads. More...
|
| |
| Runtime::BufferManagerPtr | getBufferManager () const |
| | Returns the current buffer manager. More...
|
| |
| uint64_t | getNextChunkNumber (const SeqNumberOriginId seqNumberOriginId) |
| | Returns the next chunk number belonging to a sequence number for emitting a buffer. More...
|
| |
| bool | isLastChunk (const SeqNumberOriginId seqNumberOriginId, const uint64_t chunkNumber, const bool isLastChunk) |
| | Checks if this PipelineExecutionContext has seen all chunks for a given sequence number. More...
|
| |
| void | removeSequenceState (const SeqNumberOriginId seqNumberOriginId) |
| | Removes the sequence state in seqNumberOriginIdToChunkStateInput and seqNumberOriginIdToOutputChunkNumber for the seqNumberOriginId. More...
|
| |
Public Member Functions inherited from NES::Runtime::Execution::PipelineExecutionContext