NebulaStream  0.6.213
NebulaStream is a data and application management framework for the internet of things
Windowing.hpp File Reference
#include <API/TimeUnit.hpp>
#include <memory>
Include dependency graph for Windowing.hpp:
This graph shows which files directly or indirectly include this file:

Classes

class  NES::API::WindowAggregation
 

Namespaces

 NES
 This exception represents a network error.
 
 NES::Windowing
 
 NES::API
 The following declares API functions for windowing.
 

Typedefs

using NES::Windowing::TimeCharacteristicPtr = std::shared_ptr< TimeCharacteristic >
 

Functions

API::WindowAggregationPtr NES::API::Sum (const ExpressionItem &onField)
 Defines a Sum 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...
 
API::WindowAggregationPtr NES::API::Avg (const ExpressionItem &onField)
 Defines a Agg Aggregation function on a particular field. 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...
 
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...
 
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...