NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <memory>
#include <string>
#include <variant>
Namespaces | |
NES | |
This exception represents a network error. | |
NES::Configurations | |
NES::Runtime | |
Turn this on to have Thread::current_num_threads_ keep a count of currently-active threads. | |
NES::Runtime::Execution | |
NES::Runtime::MemoryLayouts | |
NES::Network | |
NES::QueryCompilation | |
Typedefs | |
using | NES::Configurations::WorkerConfigurationPtr = std::shared_ptr< WorkerConfiguration > |
using | NES::PhysicalTypePtr = std::shared_ptr< PhysicalType > |
using | NES::DataSinkPtr = std::shared_ptr< SinkMedium > |
using | NES::DataSourcePtr = std::shared_ptr< DataSource > |
using | NES::DataEmitterPtr = std::shared_ptr< DataEmitter > |
using | NES::Runtime::PhysicalFieldPtr = std::shared_ptr< PhysicalField > |
using | NES::Runtime::PhysicalSchemaPtr = std::shared_ptr< PhysicalSchema > |
using | NES::Runtime::HardwareManagerPtr = std::shared_ptr< HardwareManager > |
using | NES::Runtime::OpenCLManagerPtr = std::shared_ptr< OpenCLManager > |
using | NES::Runtime::LocalBufferPoolPtr = std::shared_ptr< LocalBufferPool > |
using | NES::Runtime::FixedSizeBufferPoolPtr = std::shared_ptr< FixedSizeBufferPool > |
using | NES::Runtime::WorkerContextRef = WorkerContext & |
using | NES::Runtime::Execution::SuccessorExecutablePipeline = std::variant< DataSinkPtr, ExecutablePipelinePtr > |
using | NES::Runtime::Execution::PredecessorExecutablePipeline = std::variant< std::weak_ptr< DataSource >, std::weak_ptr< ExecutablePipeline > > |
using | NES::Runtime::Execution::PipelineExecutionContextPtr = std::shared_ptr< PipelineExecutionContext > |
using | NES::Runtime::MemoryLayouts::MemoryLayoutPtr = std::shared_ptr< MemoryLayout > |
using | NES::Runtime::MemoryLayouts::ColumnLayoutPtr = std::shared_ptr< ColumnLayout > |
using | NES::Runtime::MemoryLayouts::RowLayoutPtr = std::shared_ptr< RowLayout > |
Enumerations | |
enum class | NES::PipelineStageArity : uint8_t { NES::Unary , NES::BinaryLeft , NES::BinaryRight } |
enum class | NES::Runtime::NumaAwarenessFlag : int8_t { NES::Runtime::ENABLED , NES::Runtime::DISABLED } |
enum class | NES::Runtime::Execution::OperatorHandlerType : uint8_t { NES::Runtime::Execution::WINDOW , NES::Runtime::Execution::CEP , NES::Runtime::Execution::JOIN , NES::Runtime::Execution::BATCH_JOIN , NES::Runtime::Execution::KEY_EVENT_TIME_WINDOW } |