NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <API/Expressions/Expressions.hpp>
#include <API/TimeUnit.hpp>
#include <Operators/LogicalOperators/LogicalBatchJoinDescriptor.hpp>
#include <Operators/LogicalOperators/StatisticCollection/Metrics/StatisticMetric.hpp>
#include <Operators/LogicalOperators/StatisticCollection/WindowStatisticDescriptor.hpp>
#include <Operators/LogicalOperators/Windows/Joins/LogicalJoinDescriptor.hpp>
#include <memory>
#include <string>
#include <vector>
Classes | |
class | NES::JoinOperatorBuilder::Join |
class | NES::JoinOperatorBuilder::JoinWhere |
class | NES::Experimental::BatchJoinOperatorBuilder::Join |
class | NES::CrossJoinOperatorBuilder::CrossJoin |
class | NES::IntervalJoinOperatorBuilder::IntervalJoin |
class | NES::IntervalJoinOperatorBuilder::JoinWhere |
class | NES::IntervalJoinOperatorBuilder::JoinLowerBound |
class | NES::CEPOperatorBuilder::And |
class | NES::CEPOperatorBuilder::Seq |
class | NES::CEPOperatorBuilder::Times |
: This operator is a CEP operator, in CEP engines also called iteration operator. It allows for multiple occurrences of a specified event, i.e., tuples. Thus, 'times' enables patterns of arbitrary length (when only minOccurrences are defined) or requires a specified number of tuples (minOccurrence, maxOccurrence) to occur The Times operator requires the call of the window operator afterwards More... | |
class | NES::Query |
Namespaces | |
NES | |
This exception represents a network error. | |
NES::API | |
The following declares API functions for windowing. | |
NES::Catalogs | |
NES::Catalogs::UDF | |
NES::WindowOperatorBuilder | |
NES::Windowing | |
NES::JoinOperatorBuilder | |
NES::Experimental | |
create a table source | |
NES::Experimental::BatchJoinOperatorBuilder | |
BatchJoinOperatorBuilder. | |
NES::CrossJoinOperatorBuilder | |
CrossJoinOperatorBuilder. | |
NES::IntervalJoinOperatorBuilder | |
IntervalJoinOperator. | |
NES::CEPOperatorBuilder | |
Typedefs | |
using | NES::OperatorPtr = std::shared_ptr< Operator > |
using | NES::SourceLogicalOperatorPtr = std::shared_ptr< SourceLogicalOperator > |
using | NES::SinkLogicalOperatorPtr = std::shared_ptr< SinkLogicalOperator > |
using | NES::SinkDescriptorPtr = std::shared_ptr< SinkDescriptor > |
using | NES::API::WindowAggregationPtr = std::shared_ptr< WindowAggregation > |
using | NES::Catalogs::UDF::UDFDescriptorPtr = std::shared_ptr< UDFDescriptor > |
using | NES::Windowing::WindowAggregationDescriptorPtr = std::shared_ptr< WindowAggregationDescriptor > |
using | NES::Windowing::WatermarkStrategyDescriptorPtr = std::shared_ptr< WatermarkStrategyDescriptor > |
Functions | |
std::string | NES::CEPOperatorBuilder::keyAssignment (std::string keyName) |
: this function creates a virtual key for the left side of the binary operator More... | |