Package org.apache.flink.streaming.runtime.operators.util
-
Class Summary Class Description AssignerWithPeriodicWatermarksAdapter<T> An adapter that wraps aAssignerWithPeriodicWatermarksinto aWatermarkGenerator.AssignerWithPeriodicWatermarksAdapter.Strategy<T> A WatermarkStrategy that returns anAssignerWithPeriodicWatermarkswrapped as aWatermarkGenerator.AssignerWithPunctuatedWatermarksAdapter<T> An adapter that wraps aAssignerWithPunctuatedWatermarksinto aWatermarkGenerator.AssignerWithPunctuatedWatermarksAdapter.Strategy<T> A WatermarkStrategy that returns anAssignerWithPunctuatedWatermarkswrapped as aWatermarkGenerator.