|
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... | |