Uses of Class
org.apache.flink.table.runtime.operators.window.groupwindow.assigners.MergingWindowAssigner
-
-
Uses of MergingWindowAssigner in org.apache.flink.table.runtime.operators.window.groupwindow.assigners
Subclasses of MergingWindowAssigner in org.apache.flink.table.runtime.operators.window.groupwindow.assigners Modifier and Type Class Description classSessionWindowAssignerAGroupWindowAssignerthat windows elements into sessions based on the timestamp. -
Uses of MergingWindowAssigner in org.apache.flink.table.runtime.operators.window.groupwindow.internal
Constructors in org.apache.flink.table.runtime.operators.window.groupwindow.internal with parameters of type MergingWindowAssigner Constructor Description MergingWindowProcessFunction(MergingWindowAssigner<W> windowAssigner, NamespaceAggsHandleFunctionBase<W> windowAggregator, org.apache.flink.api.common.typeutils.TypeSerializer<W> windowSerializer, long allowedLateness)MergingWindowSet(MergingWindowAssigner<W> windowAssigner, org.apache.flink.api.common.state.MapState<W,W> mapping)Restores aMergingWindowSetfrom the given state. -
Uses of MergingWindowAssigner in org.apache.flink.table.runtime.operators.window.tvf.unslicing
Subclasses of MergingWindowAssigner 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.Methods in org.apache.flink.table.runtime.operators.window.tvf.unslicing that return MergingWindowAssigner Modifier and Type Method Description MergingWindowAssigner<W>UnsliceAssigner. getMergingWindowAssigner()Currently, unslice assigner has an innerMergingWindowAssignerto reuse the logic inGroupWindowAssignerto merge windows.MergingWindowAssigner<TimeWindow>UnsliceAssigners.SessionUnsliceAssigner. getMergingWindowAssigner()MergingWindowAssigner<TimeWindow>UnsliceAssigners.WindowedUnsliceAssigner. getMergingWindowAssigner()
-