Uses of Class
org.apache.flink.table.runtime.operators.window.groupwindow.internal.MergingWindowProcessFunction
-
Packages that use MergingWindowProcessFunction Package Description org.apache.flink.table.runtime.operators.aggregate.window.processors org.apache.flink.table.runtime.operators.window.tvf.unslicing -
-
Uses of MergingWindowProcessFunction in org.apache.flink.table.runtime.operators.aggregate.window.processors
Fields in org.apache.flink.table.runtime.operators.aggregate.window.processors declared as MergingWindowProcessFunction Modifier and Type Field Description protected MergingWindowProcessFunction<org.apache.flink.table.data.RowData,TimeWindow>UnsliceSyncStateWindowAggProcessor. windowFunction -
Uses of MergingWindowProcessFunction in org.apache.flink.table.runtime.operators.window.tvf.unslicing
Methods in org.apache.flink.table.runtime.operators.window.tvf.unslicing with parameters of type MergingWindowProcessFunction Modifier and Type Method Description Optional<W>UnsliceAssigner. assignActualWindow(org.apache.flink.table.data.RowData element, ClockService clock, MergingWindowProcessFunction<?,W> windowFunction)Returns theWindowthat the given element should belong to be used to trigger on.Optional<TimeWindow>UnsliceAssigners.SessionUnsliceAssigner. assignActualWindow(org.apache.flink.table.data.RowData element, ClockService clock, MergingWindowProcessFunction<?,TimeWindow> windowFunction)Optional<TimeWindow>UnsliceAssigners.WindowedUnsliceAssigner. assignActualWindow(org.apache.flink.table.data.RowData element, ClockService clock, MergingWindowProcessFunction<?,TimeWindow> windowFunction)Optional<W>UnsliceAssigner. assignStateNamespace(org.apache.flink.table.data.RowData element, ClockService clock, MergingWindowProcessFunction<?,W> windowFunction)Returns theWindowthat the given element should belong to be used as a namespace to restore the state.Optional<TimeWindow>UnsliceAssigners.SessionUnsliceAssigner. assignStateNamespace(org.apache.flink.table.data.RowData element, ClockService clock, MergingWindowProcessFunction<?,TimeWindow> windowFunction)Optional<TimeWindow>UnsliceAssigners.WindowedUnsliceAssigner. assignStateNamespace(org.apache.flink.table.data.RowData element, ClockService clock, MergingWindowProcessFunction<?,TimeWindow> windowFunction)
-