NES::Windowing Namespace Reference

Classes
class	MultiOriginWatermarkProcessor
	The watermark processor receives watermark barriers and provides the current watermark across multiple origins. The watermark processor guarantees strict serializable watermark updates. Thus, a watermark processor is only executed if all preceding updates have been processed. Consequently, the watermark processor expects a exactly once delivery on the input channel. More...
class	WatermarkProcessor
	This class implements a watermark processor for a single origin. It processes all watermark updates from one specific origin and applies all updates in sequential order. @assumptions This watermark processor assumes strictly monotonic update sequence numbers. To handle out of order processing, it stores in flight updates in a transaction log. More...
class	TimeUnit

Typedefs
using	WindowTypePtr = std::shared_ptr< WindowType >
using	WindowAggregationDescriptorPtr = std::shared_ptr< WindowAggregationDescriptor >
using	WatermarkStrategyDescriptorPtr = std::shared_ptr< WatermarkStrategyDescriptor >
using	TimeCharacteristicPtr = std::shared_ptr< TimeCharacteristic >
using	LogicalWindowDescriptorPtr = std::shared_ptr< LogicalWindowDescriptor >
using	WindowOperatorHandlerPtr = std::shared_ptr< WindowOperatorHandler >
using	MultiOriginWatermarkProcessorPtr = std::unique_ptr< MultiOriginWatermarkProcessor >

Typedef Documentation

LogicalWindowDescriptorPtr

using NES::Windowing::LogicalWindowDescriptorPtr = typedef std::shared_ptr<LogicalWindowDescriptor>

MultiOriginWatermarkProcessorPtr

using NES::Windowing::MultiOriginWatermarkProcessorPtr = typedef std::unique_ptr<MultiOriginWatermarkProcessor>

TimeCharacteristicPtr

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

WatermarkStrategyDescriptorPtr

typedef std::shared_ptr< WatermarkStrategyDescriptor > NES::Windowing::WatermarkStrategyDescriptorPtr

WindowAggregationDescriptorPtr

typedef std::shared_ptr< WindowAggregationDescriptor > NES::Windowing::WindowAggregationDescriptorPtr

WindowOperatorHandlerPtr

using NES::Windowing::WindowOperatorHandlerPtr = typedef std::shared_ptr<WindowOperatorHandler>

WindowTypePtr

typedef std::shared_ptr< WindowType > NES::Windowing::WindowTypePtr