Package org.apache.flink.table.runtime.operators.window.groupwindow.internal
-
Interface Summary Interface Description InternalWindowProcessFunction.Context<K,W extends Window> Information available in an invocation of methods ofInternalWindowProcessFunction.MergingWindowProcessFunction.MergingContext<K,W extends Window> MergingWindowSet.MergeFunction<W> Callback forMergingWindowSet.addWindow(Window, MergeFunction). -
Class Summary Class Description GeneralWindowProcessFunction<K,W extends Window> The general implementation ofInternalWindowProcessFunction.InternalWindowProcessFunction<K,W extends Window> The internal interface for functions that process over grouped windows.MergingWindowProcessFunction<K,W extends Window> The implementation ofInternalWindowProcessFunctionforMergingWindowAssigner.MergingWindowProcessFunction.DefaultAccMergingConsumer<W extends Window> A default merging consumer that merges the accumulators in state windows that waiting to be merged into the target state window.MergingWindowSet<W extends Window> Utility for keeping track of mergingWindowswhen using aMergingWindowAssignerin aWindowOperator.PanedWindowProcessFunction<K,W extends Window> The implementation ofInternalWindowProcessFunctionforPanedWindowAssigner.