NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
PipelineExecutionContext.hpp File Reference
#include <Exceptions/RuntimeException.hpp>
#include <Identifiers/Identifiers.hpp>
#include <Runtime/RuntimeForwardRefs.hpp>
#include <Util/Common.hpp>
#include <cstdint>
#include <folly/Synchronized.h>
#include <functional>
#include <map>
#include <memory>
#include <vector>
Include dependency graph for PipelineExecutionContext.hpp:
This graph shows which files directly or indirectly include this file:

Classes

struct  NES::Runtime::Execution::SeqNumberOriginId
 Stores a sequenceNumber and an OriginId. More...
 
struct  NES::Runtime::Execution::SequenceState
 Container for storing information, related to the state of a sequence number. More...
 
class  NES::Runtime::Execution::PipelineExecutionContext
 The PipelineExecutionContext is passed to a compiled pipeline and offers basic functionality to interact with the Runtime. Via the context, the compile code is able to allocate new TupleBuffers and to emit tuple buffers to the Runtime. More...
 

Namespaces

 NES
 This exception represents a network error.
 
 NES::Runtime
 Turn this on to have Thread::current_num_threads_ keep a count of currently-active threads.
 
 NES::Runtime::Execution