Uses of Interface
org.apache.flink.table.runtime.operators.window.tvf.common.WindowAssigner
-
-
Uses of WindowAssigner in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors
Constructors in org.apache.flink.table.runtime.operators.aggregate.asyncwindow.processors with parameters of type WindowAssigner Constructor Description AbstractAsyncStateWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<W> genAggsHandler, WindowAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, boolean isEventTime, int indexOfCountStar, ZoneId shiftTimeZone, W defaultWindow) -
Uses of WindowAssigner in org.apache.flink.table.runtime.operators.aggregate.window
Methods in org.apache.flink.table.runtime.operators.aggregate.window with parameters of type WindowAssigner Modifier and Type Method Description WindowAggOperatorBuilderWindowAggOperatorBuilder. assigner(WindowAssigner assigner) -
Uses of WindowAssigner in org.apache.flink.table.runtime.operators.aggregate.window.processors
Constructors in org.apache.flink.table.runtime.operators.aggregate.window.processors with parameters of type WindowAssigner Constructor Description AbstractSyncStateWindowAggProcessor(GeneratedNamespaceAggsHandleFunction<W> genAggsHandler, WindowAssigner sliceAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> accSerializer, boolean isEventTime, int indexOfCountStar, ZoneId shiftTimeZone) -
Uses of WindowAssigner in org.apache.flink.table.runtime.operators.window.tvf.slicing
Subinterfaces of WindowAssigner in org.apache.flink.table.runtime.operators.window.tvf.slicing Modifier and Type Interface Description interfaceSliceAssignerASliceAssignerassigns element into a single slice.interfaceSliceSharedAssignerASliceAssignerwhich shares slices for windows, which means a window is divided into multiple slices and need to merge the slices into windows when emitting windows.interfaceSliceUnsharedAssignerASliceAssignerwhich 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.Classes in org.apache.flink.table.runtime.operators.window.tvf.slicing that implement WindowAssigner Modifier and Type Class Description static classSliceAssigners.CumulativeSliceAssignerTheSliceAssignerfor cumulative windows.static classSliceAssigners.HoppingSliceAssignerTheSliceAssignerfor hopping windows.static classSliceAssigners.SlicedSharedSliceAssignerTheSliceAssignerfor elements have been attached slice end timestamp, and the slices are shared.static classSliceAssigners.SlicedUnsharedSliceAssignerTheSliceAssignerfor elements have been attached slice end timestamp, but the slices are not shared, i.e. the assigned slice is equal to the final window.static classSliceAssigners.TumblingSliceAssignerTheSliceAssignerfor tumbling windows.static classSliceAssigners.WindowedSliceAssignerTheSliceAssignerfor elements have been attached window start and end timestamps. -
Uses of WindowAssigner in org.apache.flink.table.runtime.operators.window.tvf.unslicing
Subinterfaces of WindowAssigner in org.apache.flink.table.runtime.operators.window.tvf.unslicing Modifier and Type Interface Description interfaceUnsliceAssigner<W extends Window>AUnsliceAssignerassigns each element into a single window and not divides the window into finite number of non-overlapping slice.Classes in org.apache.flink.table.runtime.operators.window.tvf.unslicing that implement WindowAssigner Modifier and Type Class Description static classUnsliceAssigners.SessionUnsliceAssignerTheUnsliceAssignerfor session windows.static classUnsliceAssigners.WindowedUnsliceAssignerTheUnsliceAssignerfor elements have been merged into unslicing windows and attached window start and end timestamps.
-