NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
List of all members
SimpleGPUPipelineStage Class Reference
Collaboration diagram for SimpleGPUPipelineStage:
[legend]

Additional Inherited Members

- Public Member Functions inherited from NES::Runtime::Execution::ExecutablePipelineStage
virtual ~ExecutablePipelineStage ()=default
 
 ExecutablePipelineStage (PipelineStageArity arity=PipelineStageArity::Unary)
 
PipelineStageArity getArity () const
 Returns the arity of this pipeline. More...
 
virtual uint32_t start (PipelineExecutionContext &pipelineExecutionContext)
 Must be called only once per executable pipeline and starts the executable pipeline. e.g. starts the threads for the window handler. More...
 
virtual uint32_t open (PipelineExecutionContext &pipelineExecutionContext, WorkerContext &workerContext)
 Must be called exactly once per worker thread and initializes worker local state. For instance a worker local aggregation state. More...
 
virtual uint32_t close (PipelineExecutionContext &pipelineExecutionContext, WorkerContext &workerContext)
 Must be called exactly once per worker thread to remove worker local state. More...
 
virtual std::string getCodeAsString ()
 return the code of the pipeline More...
 
The documentation for this class was generated from the following file: