T
- The type of elements that this WindowAssigner can assign windows to.W
- The type of Window
that this assigner assigns.@PublicEvolving public abstract class MergingWindowAssigner<T,W extends Window> extends WindowAssigner<T,W>
WindowAssigner
that can merge windows.Modifier and Type | Class and Description |
---|---|
static interface |
MergingWindowAssigner.MergeCallback<W>
Callback to be used in
mergeWindows(Collection, MergeCallback) for specifying which
windows should be merged. |
WindowAssigner.WindowAssignerContext
Constructor and Description |
---|
MergingWindowAssigner() |
Modifier and Type | Method and Description |
---|---|
abstract void |
mergeWindows(Collection<W> windows,
MergingWindowAssigner.MergeCallback<W> callback)
Determines which windows (if any) should be merged.
|
assignWindows, getDefaultTrigger, getWindowSerializer, isEventTime
public abstract void mergeWindows(Collection<W> windows, MergingWindowAssigner.MergeCallback<W> callback)
windows
- The window candidates.callback
- A callback that can be invoked to signal which windows should be merged.Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.