NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#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>
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 | |