Interface | Description |
---|---|
InternalWindowProcessFunction.Context<K,W extends Window> |
Information available in an invocation of methods of
InternalWindowProcessFunction . |
MergingWindowSet.MergeFunction<W> |
Callback for
MergingWindowSet.addWindow(Window, MergeFunction) . |
Class | Description |
---|---|
GeneralWindowProcessFunction<K,W extends Window> |
The general implementation of
InternalWindowProcessFunction . |
InternalWindowProcessFunction<K,W extends Window> |
The internal interface for functions that process over grouped windows.
|
MergingWindowProcessFunction<K,W extends Window> |
The implementation of
InternalWindowProcessFunction for MergingWindowAssigner . |
MergingWindowSet<W extends Window> |
Utility for keeping track of merging
Windows when using a MergingWindowAssigner in a WindowOperator . |
PanedWindowProcessFunction<K,W extends Window> |
The implementation of
InternalWindowProcessFunction for PanedWindowAssigner . |
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.