Package org.apache.flink.table.runtime.operators.window.tvf.unslicing
-
Interface Summary Interface Description UnsliceAssigner<W extends Window> AUnsliceAssignerassigns each element into a single window and not divides the window into finite number of non-overlapping slice.UnslicingSyncStateWindowProcessor<W> TheUnslicingSyncStateWindowProcessoris an optimized processing for unaligned windows. -
Class Summary Class Description UnsliceAssigners Utilities to createUnsliceAssigners.UnsliceAssigners.SessionUnsliceAssigner TheUnsliceAssignerfor session windows.UnsliceAssigners.WindowedUnsliceAssigner TheUnsliceAssignerfor elements have been merged into unslicing windows and attached window start and end timestamps.UnslicingWindowTimerServiceImpl AWindowTimerServicefor unslicing window.