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

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

close(PipelineExecutionContext &pipelineExecutionContext, WorkerContext &workerContext)NES::Runtime::Execution::ExecutablePipelineStagevirtual
completedPromiseNES::TextExecutablePipeline
countNES::TextExecutablePipeline
ExecutablePipelineStage(PipelineStageArity arity=PipelineStageArity::Unary)NES::Runtime::Execution::ExecutablePipelineStageinlineexplicit
execute(TupleBuffer &inputTupleBuffer, PipelineExecutionContext &pipelineExecutionContext, WorkerContext &wctx) overrideNES::TextExecutablePipelineinlinevirtual
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
sumNES::TextExecutablePipeline
~ExecutablePipelineStage()=defaultNES::Runtime::Execution::ExecutablePipelineStagevirtual
~TextExecutablePipeline()=defaultNES::TextExecutablePipelinevirtual