Uses of Class
org.apache.flink.table.runtime.operators.window.assigners.WindowAssigner
-
-
Uses of WindowAssigner in org.apache.flink.table.runtime.operators.window
Fields in org.apache.flink.table.runtime.operators.window declared as WindowAssigner Modifier and Type Field Description protected WindowAssigner<?>WindowOperatorBuilder. windowAssignerMethods in org.apache.flink.table.runtime.operators.window with parameters of type WindowAssigner Modifier and Type Method Description WindowOperatorBuilderWindowOperatorBuilder. assigner(WindowAssigner<?> windowAssigner)Constructors in org.apache.flink.table.runtime.operators.window with parameters of type WindowAssigner Constructor Description WindowTableFunctionOperator(WindowAssigner<TimeWindow> windowAssigner, int rowtimeIndex, java.time.ZoneId shiftTimeZone) -
Uses of WindowAssigner in org.apache.flink.table.runtime.operators.window.assigners
Subclasses of WindowAssigner in org.apache.flink.table.runtime.operators.window.assigners Modifier and Type Class Description classCountSlidingWindowAssignerAWindowAssignerthat windows elements into sliding windows based on the count number of the elements.classCountTumblingWindowAssignerAWindowAssignerthat windows elements into fixed-size windows based on the count number of the elements.classCumulativeWindowAssignerAWindowAssignerthat windows elements into cumulative windows based on the timestamp of the elements.classMergingWindowAssigner<W extends Window>AWindowAssignerthat can merge windows.classPanedWindowAssigner<W extends Window>AWindowAssignerthat window can be split into panes.classSessionWindowAssignerAWindowAssignerthat windows elements into sessions based on the timestamp.classSlidingWindowAssignerAWindowAssignerthat windows elements into sliding windows based on the timestamp of the elements.classTumblingWindowAssignerAWindowAssignerthat windows elements into fixed-size windows based on the timestamp of the elements. -
Uses of WindowAssigner in org.apache.flink.table.runtime.operators.window.internal
Fields in org.apache.flink.table.runtime.operators.window.internal declared as WindowAssigner Modifier and Type Field Description protected WindowAssigner<W>InternalWindowProcessFunction. windowAssignerConstructors in org.apache.flink.table.runtime.operators.window.internal with parameters of type WindowAssigner Constructor Description GeneralWindowProcessFunction(WindowAssigner<W> windowAssigner, NamespaceAggsHandleFunctionBase<W> windowAggregator, long allowedLateness)InternalWindowProcessFunction(WindowAssigner<W> windowAssigner, NamespaceAggsHandleFunctionBase<W> windowAggregator, long allowedLateness)
-