W
- The type of Window
that this assigner assigns.public abstract class MergingWindowAssigner<W extends Window> extends WindowAssigner<W>
WindowAssigner
that can merge windows.Modifier and Type | Class and Description |
---|---|
static interface |
MergingWindowAssigner.MergeCallback<W>
Callback to be used in
mergeWindows(Window, NavigableSet, MergeCallback) for
specifying which windows should be merged. |
Constructor and Description |
---|
MergingWindowAssigner() |
Modifier and Type | Method and Description |
---|---|
abstract void |
mergeWindows(W newWindow,
NavigableSet<W> sortedWindows,
MergingWindowAssigner.MergeCallback<W> callback)
Determines which windows (if any) should be merged.
|
assignWindows, getWindowSerializer, isEventTime, open, toString
public abstract void mergeWindows(W newWindow, NavigableSet<W> sortedWindows, MergingWindowAssigner.MergeCallback<W> callback)
newWindow
- The new windowsortedWindows
- The sorted window candidates.callback
- A callback that can be invoked to signal which windows should be merged.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.