Uses of Class
org.apache.flink.table.runtime.operators.window.groupwindow.assigners.GroupWindowAssigner
-
-
Uses of GroupWindowAssigner in org.apache.flink.table.runtime.operators.window.groupwindow.assigners
Subclasses of GroupWindowAssigner in org.apache.flink.table.runtime.operators.window.groupwindow.assigners Modifier and Type Class Description classCountSlidingWindowAssignerAGroupWindowAssignerthat windows elements into sliding windows based on the count number of the elements.classCountTumblingWindowAssignerAGroupWindowAssignerthat windows elements into fixed-size windows based on the count number of the elements.classCumulativeWindowAssignerAGroupWindowAssignerthat 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.classSessionWindowAssignerAGroupWindowAssignerthat windows elements into sessions based on the timestamp.classSlidingWindowAssignerAGroupWindowAssignerthat windows elements into sliding windows based on the timestamp of the elements.classTumblingWindowAssignerAGroupWindowAssignerthat windows elements into fixed-size windows based on the timestamp of the elements. -
Uses of GroupWindowAssigner in org.apache.flink.table.runtime.operators.window.groupwindow.internal
Fields in org.apache.flink.table.runtime.operators.window.groupwindow.internal declared as GroupWindowAssigner Modifier and Type Field Description protected GroupWindowAssigner<W>InternalWindowProcessFunction. windowAssignerConstructors in org.apache.flink.table.runtime.operators.window.groupwindow.internal with parameters of type GroupWindowAssigner Constructor Description GeneralWindowProcessFunction(GroupWindowAssigner<W> windowAssigner, NamespaceAggsHandleFunctionBase<W> windowAggregator, long allowedLateness)InternalWindowProcessFunction(GroupWindowAssigner<W> windowAssigner, NamespaceAggsHandleFunctionBase<W> windowAggregator, long allowedLateness) -
Uses of GroupWindowAssigner in org.apache.flink.table.runtime.operators.window.groupwindow.operator
Fields in org.apache.flink.table.runtime.operators.window.groupwindow.operator declared as GroupWindowAssigner Modifier and Type Field Description protected GroupWindowAssigner<?>WindowOperatorBuilder. windowAssignerMethods in org.apache.flink.table.runtime.operators.window.groupwindow.operator with parameters of type GroupWindowAssigner Modifier and Type Method Description WindowOperatorBuilderWindowOperatorBuilder. assigner(GroupWindowAssigner<?> windowAssigner) -
Uses of GroupWindowAssigner in org.apache.flink.table.runtime.operators.window.tvf.operator
Fields in org.apache.flink.table.runtime.operators.window.tvf.operator declared as GroupWindowAssigner Modifier and Type Field Description protected GroupWindowAssigner<TimeWindow>WindowTableFunctionOperatorBase. windowAssignerConstructors in org.apache.flink.table.runtime.operators.window.tvf.operator with parameters of type GroupWindowAssigner Constructor Description AlignedWindowTableFunctionOperator(GroupWindowAssigner<TimeWindow> windowAssigner, int rowtimeIndex, ZoneId shiftTimeZone)UnalignedWindowTableFunctionOperator(GroupWindowAssigner<TimeWindow> windowAssigner, org.apache.flink.api.common.typeutils.TypeSerializer<TimeWindow> windowSerializer, org.apache.flink.api.common.typeutils.TypeSerializer<org.apache.flink.table.data.RowData> inputSerializer, int rowtimeIndex, ZoneId shiftTimeZone)WindowTableFunctionOperatorBase(GroupWindowAssigner<TimeWindow> windowAssigner, int rowtimeIndex, ZoneId shiftTimeZone) -
Uses of GroupWindowAssigner in org.apache.flink.table.runtime.operators.window.tvf.unslicing
Subclasses of GroupWindowAssigner in org.apache.flink.table.runtime.operators.window.tvf.unslicing Modifier and Type Class Description static classUnsliceAssigners.WindowedUnsliceAssignerTheUnsliceAssignerfor elements have been merged into unslicing windows and attached window start and end timestamps.
-