org.apache.flink.streaming.api.windowing.assigners

Interface MergingWindowAssigner.MergeCallback<W>

Enclosing class:

MergingWindowAssigner<T,W extends Window>

@PublicEvolving
public static interface MergingWindowAssigner.MergeCallback<W>

Callback to be used in MergingWindowAssigner.mergeWindows(Collection, MergeCallback) for specifying which windows should be merged.

Method Summary

Modifier and Type	Method and Description
void	merge(Collection<W> toBeMerged, W mergeResult) Specifies that the given windows should be merged into the result window.

Method Detail

merge

void merge(Collection<W> toBeMerged,
           W mergeResult)

Specifies that the given windows should be merged into the result window.

Parameters:

toBeMerged - The list of windows that should be merged into one window.

mergeResult - The resulting merged window.