NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
Windowing.cpp File Reference
#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>
Include dependency graph for Windowing.cpp:

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