Package org.apache.flink.table.runtime.operators.window.assigners

Class MergingWindowAssigner<W extends Window>

java.lang.Object

org.apache.flink.table.runtime.operators.window.assigners.WindowAssigner<W>

org.apache.flink.table.runtime.operators.window.assigners.MergingWindowAssigner<W>

Type Parameters:

W - The type of Window that this assigner assigns.

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

SessionWindowAssigner

public abstract class MergingWindowAssigner<W extends Window>
extends WindowAssigner<W>

A WindowAssigner that can merge windows.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static interface	MergingWindowAssigner.MergeCallback<W>	Callback to be used in mergeWindows(Window, NavigableSet, MergeCallback) for specifying which windows should be merged.

Constructor Summary

Constructors

Constructor	Description
MergingWindowAssigner()

Method Summary

Modifier and Type	Method	Description
abstract void	mergeWindows(W newWindow, NavigableSet<W> sortedWindows, MergingWindowAssigner.MergeCallback<W> callback)	Determines which windows (if any) should be merged.

Methods inherited from class org.apache.flink.table.runtime.operators.window.assigners.WindowAssigner

assignWindows, getWindowSerializer, isEventTime, open, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

MergingWindowAssigner

public MergingWindowAssigner()

Method Detail

mergeWindows

public abstract void mergeWindows(W newWindow,
                                  NavigableSet<W> sortedWindows,
                                  MergingWindowAssigner.MergeCallback<W> callback)

Determines which windows (if any) should be merged.

Parameters:

newWindow - The new window

sortedWindows - The sorted window candidates.

callback - A callback that can be invoked to signal which windows should be merged.