Package org.apache.flink.table.runtime.operators.window.slicing

Interface Summary

Interface	Description
ClockService	A clock service which can get current processing time.
SliceAssigner	A SliceAssigner assigns element into a single slice.
SliceSharedAssigner	A SliceAssigner which shares slices for windows, which means a window is divided into multiple slices and need to merge the slices into windows when emitting windows.
SliceSharedAssigner.MergeCallback	Callback to be used in SliceSharedAssigner.mergeSlices(long, MergeCallback) for specifying which slices should be merged.
SliceUnsharedAssigner	A SliceAssigner which 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>	A processor that processes elements for slicing windows.
SlicingWindowProcessor.Context<W>	Information available in an invocation of methods of SlicingWindowProcessor.
WindowTimerService<W>	Interface for working with window time and timers which considers timezone for window splitting.

Class Summary

Class	Description
SliceAssigners	Utilities to create SliceAssigners.
SliceAssigners.CumulativeSliceAssigner	The SliceAssigner for cumulative windows.
SliceAssigners.HoppingSliceAssigner	The SliceAssigner for hopping windows.
SliceAssigners.SlicedSharedSliceAssigner	The SliceAssigner for elements have been attached slice end timestamp, and the slices are shared.
SliceAssigners.SlicedUnsharedSliceAssigner	The SliceAssigner for elements have been attached slice end timestamp, but the slices are not shared, i.e.
SliceAssigners.TumblingSliceAssigner	The SliceAssigner for tumbling windows.
SliceAssigners.WindowedSliceAssigner	The SliceAssigner for elements have been attached window start and end timestamps.
SlicingWindowOperator<K,W>	The SlicingWindowOperator implements an optimized processing for aligned windows which can apply the slicing optimization.
WindowTimerServiceImpl	Simple Implements of WindowTimerService.