Package org.apache.flink.table.runtime.operators.wmassigners

Class Summary

Class	Description
BoundedOutOfOrderWatermarkGenerator	A watermark generator for rowtime attributes which are out-of-order by a bounded time interval.
PeriodicWatermarkAssignerWrapper	Generates periodic watermarks based on a PeriodicWatermarkAssigner.
ProcTimeMiniBatchAssignerOperator	A stream operator that emits mini-batch marker in a given period.
PunctuatedWatermarkStrategyWrapper	Generates periodic watermarks based on a PunctuatedWatermarkAssigner.
RowTimeMiniBatchAssginerOperator	A stream operator that emits watermark in a given event-time interval.
WatermarkAssignerOperator	A stream operator that extracts timestamps from stream elements and generates periodic watermarks.
WatermarkAssignerOperatorFactory	The factory of WatermarkAssignerOperator.