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

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

close(PipelineExecutionContext &pipelineExecutionContext, WorkerContext &workerContext)NES::Runtime::Execution::ExecutablePipelineStagevirtual
completedPromiseNES::MockedExecutablePipeline
countNES::MockedExecutablePipeline
ExecutablePipelineStage(PipelineStageArity arity=PipelineStageArity::Unary)NES::Runtime::Execution::ExecutablePipelineStageinlineexplicit
execute(Runtime::TupleBuffer &inputTupleBuffer, Runtime::Execution::PipelineExecutionContext &pipelineExecutionContext, Runtime::WorkerContext &wctx) overrideNES::MockedExecutablePipelineinlinevirtual
getArity() constNES::Runtime::Execution::ExecutablePipelineStageinline
getCodeAsString()NES::Runtime::Execution::ExecutablePipelineStagevirtual
open(PipelineExecutionContext &pipelineExecutionContext, WorkerContext &workerContext)NES::Runtime::Execution::ExecutablePipelineStagevirtual
setup(PipelineExecutionContext &pipelineExecutionContext)NES::Runtime::Execution::ExecutablePipelineStagevirtual
start(PipelineExecutionContext &pipelineExecutionContext)NES::Runtime::Execution::ExecutablePipelineStagevirtual
stop(PipelineExecutionContext &pipelineExecutionContext)NES::Runtime::Execution::ExecutablePipelineStagevirtual
~ExecutablePipelineStage()=defaultNES::Runtime::Execution::ExecutablePipelineStagevirtual