Package org.apache.flink.table.runtime.operators.window.tvf.slicing
-
Interface Summary Interface Description SliceAssigner ASliceAssignerassigns element into a single slice.SliceSharedAssigner ASliceAssignerwhich shares slices for windows, which means a window is divided into multiple slices and need to merge the slices into windows when emitting windows.SliceUnsharedAssigner ASliceAssignerwhich doesn't share slices for windows, which means a window is divided into only one slice and doesn't need to merge the slices when emitting windows.SlicingWindowProcessor<W> TheSlicingWindowProcessoris an optimized processing for aligned windows which can apply the slicing optimization. -
Class Summary Class Description SliceAssigners Utilities to createSliceAssigners.SliceAssigners.CumulativeSliceAssigner TheSliceAssignerfor cumulative windows.SliceAssigners.HoppingSliceAssigner TheSliceAssignerfor hopping windows.SliceAssigners.SlicedSharedSliceAssigner TheSliceAssignerfor elements have been attached slice end timestamp, and the slices are shared.SliceAssigners.SlicedUnsharedSliceAssigner TheSliceAssignerfor elements have been attached slice end timestamp, but the slices are not shared, i.e.SliceAssigners.TumblingSliceAssigner TheSliceAssignerfor tumbling windows.SliceAssigners.WindowedSliceAssigner TheSliceAssignerfor elements have been attached window start and end timestamps.SlicingWindowTimerServiceImpl AWindowTimerServicefor slicing window.