Uses of Package
org.apache.flink.table.runtime.operators.window.slicing
-
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.aggregate.window Class Description SliceAssigner ASliceAssignerassigns element into a single slice.SlicingWindowOperator TheSlicingWindowOperatorimplements an optimized processing for aligned windows which can apply the slicing optimization. -
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.aggregate.window.buffers Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.aggregate.window.combines Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.aggregate.window.processors Class Description ClockService A clock service which can get current processing time.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.SliceSharedAssigner.MergeCallback Callback to be used inSliceSharedAssigner.mergeSlices(long, MergeCallback)for specifying which slices should be merged.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 A processor that processes elements for slicing windows.SlicingWindowProcessor.Context Information available in an invocation of methods ofSlicingWindowProcessor.WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.deduplicate.window Class Description SlicingWindowOperator TheSlicingWindowOperatorimplements an optimized processing for aligned windows which can apply the slicing optimization. -
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.deduplicate.window.combines Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.deduplicate.window.processors Class Description SlicingWindowProcessor A processor that processes elements for slicing windows.SlicingWindowProcessor.Context Information available in an invocation of methods ofSlicingWindowProcessor. -
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.rank.window Class Description SlicingWindowOperator TheSlicingWindowOperatorimplements an optimized processing for aligned windows which can apply the slicing optimization. -
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.rank.window.combines Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.rank.window.processors Class Description SlicingWindowProcessor A processor that processes elements for slicing windows.SlicingWindowProcessor.Context Information available in an invocation of methods ofSlicingWindowProcessor. -
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.window.combines Class Description WindowTimerService Interface for working with window time and timers which considers timezone for window splitting. -
Classes in org.apache.flink.table.runtime.operators.window.slicing used by org.apache.flink.table.runtime.operators.window.slicing Class Description ClockService A clock service which can get current processing time.SliceAssigner ASliceAssignerassigns element into a single slice.SliceAssigners.CumulativeSliceAssigner TheSliceAssignerfor cumulative windows.SliceAssigners.HoppingSliceAssigner TheSliceAssignerfor hopping windows.SliceAssigners.TumblingSliceAssigner TheSliceAssignerfor tumbling windows.SliceAssigners.WindowedSliceAssigner TheSliceAssignerfor elements have been attached window start and end timestamps.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.SliceSharedAssigner.MergeCallback Callback to be used inSliceSharedAssigner.mergeSlices(long, MergeCallback)for specifying which slices should be merged.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 A processor that processes elements for slicing windows.SlicingWindowProcessor.Context Information available in an invocation of methods ofSlicingWindowProcessor.WindowTimerService Interface for working with window time and timers which considers timezone for window splitting.