Package org.apache.flink.streaming.runtime.operators.windowing

Interface MergingWindowSet.MergeFunction<W>

Type Parameters:

W -

Enclosing class:

MergingWindowSet<W extends Window>

public static interface MergingWindowSet.MergeFunction<W>

Callback for MergingWindowSet.addWindow(Window, MergeFunction).

Method Summary

Modifier and Type	Method	Description
void	merge(W mergeResult, Collection<W> mergedWindows, W stateWindowResult, Collection<W> mergedStateWindows)	This gets called when a merge occurs.

Method Detail

merge

void merge(W mergeResult,
           Collection<W> mergedWindows,
           W stateWindowResult,
           Collection<W> mergedStateWindows)
    throws Exception

This gets called when a merge occurs.

Parameters:

mergeResult - The newly resulting merged Window.

mergedWindows - The merged Window Windows.

stateWindowResult - The state window of the merge result.

mergedStateWindows - The merged state windows.

Throws:

Exception