NebulaStream
0.6.213
NebulaStream is a data and application management framework for the internet of things
|
#include <API/Expressions/Expressions.hpp>
#include <API/Windowing.hpp>
#include <Expressions/FieldAccessExpressionNode.hpp>
#include <Measures/TimeCharacteristic.hpp>
#include <Measures/TimeMeasure.hpp>
#include <Operators/LogicalOperators/Windows/Aggregations/AvgAggregationDescriptor.hpp>
#include <Operators/LogicalOperators/Windows/Aggregations/CountAggregationDescriptor.hpp>
#include <Operators/LogicalOperators/Windows/Aggregations/MaxAggregationDescriptor.hpp>
#include <Operators/LogicalOperators/Windows/Aggregations/MedianAggregationDescriptor.hpp>
#include <Operators/LogicalOperators/Windows/Aggregations/MinAggregationDescriptor.hpp>
#include <Operators/LogicalOperators/Windows/Aggregations/SumAggregationDescriptor.hpp>
#include <utility>
Namespaces | |
NES | |
This exception represents a network error. | |
NES::API | |
The following declares API functions for windowing. | |
Functions | |
API::WindowAggregationPtr | NES::API::Sum (const ExpressionItem &onField) |
Defines a Sum Aggregation function on a particular field. More... | |
API::WindowAggregationPtr | NES::API::Avg (const ExpressionItem &onField) |
Defines a Agg Aggregation function on a particular field. More... | |
API::WindowAggregationPtr | NES::API::Min (const ExpressionItem &onField) |
Defines a Min Aggregation function on a particular field. More... | |
API::WindowAggregationPtr | NES::API::Max (const ExpressionItem &onField) |
Defines a Max Aggregation function on a particular field. More... | |
API::WindowAggregationPtr | NES::API::Count () |
Defines a Count Aggregation function on a particular field. More... | |
API::WindowAggregationPtr | NES::API::Median (const ExpressionItem &onField) |
Defines a Median Aggregation function on a particular field. More... | |
Windowing::TimeMeasure | NES::API::Milliseconds (uint64_t milliseconds) |
A time measure in Milliseconds. More... | |
Windowing::TimeMeasure | NES::API::Seconds (uint64_t seconds) |
A time measure in Seconds. More... | |
Windowing::TimeMeasure | NES::API::Minutes (uint64_t minutes) |
A time measure in Minutes. More... | |
Windowing::TimeMeasure | NES::API::Hours (uint64_t hours) |
A time measure in Hours. More... | |
Windowing::TimeMeasure | NES::API::Days (uint64_t days) |
A time measure in Days. More... | |
Windowing::TimeUnit | NES::API::Milliseconds () |
A time unit in Milliseconds. More... | |
Windowing::TimeUnit | NES::API::Seconds () |
A time unit in Seconds. More... | |
Windowing::TimeUnit | NES::API::Minutes () |
A time unit in Minutes. More... | |
Windowing::TimeUnit | NES::API::Hours () |
A time unit in Hours. More... | |
Windowing::TimeUnit | NES::API::Days () |
A time unit in Days. More... | |
Windowing::TimeCharacteristicPtr | NES::API::EventTime (const ExpressionItem &onField) |
Defines event time as a time characteristic for a window. More... | |
Windowing::TimeCharacteristicPtr | NES::API::EventTime (const ExpressionItem &onField, const Windowing::TimeUnit &unit) |
Defines event time as a time characteristic for a window. More... | |
Windowing::TimeCharacteristicPtr | NES::API::IngestionTime () |
Defines a ingestion time as a time characteristic for a window. More... | |
ExpressionNodePtr | NES::API::RecordCreationTs () |
This function provides access to the creation ts (ingestion ts) of an individual record. This is assigned by the data source. More... | |