Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.transforms.windowing
Class WindowFn.MergeContext
- java.lang.Object
-
- com.google.cloud.dataflow.sdk.transforms.windowing.WindowFn.MergeContext
-
- Enclosing class:
- WindowFn<T,W extends BoundedWindow>
public abstract class WindowFn.MergeContext extends Object
Information available when runningWindowFn.mergeWindows(com.google.cloud.dataflow.sdk.transforms.windowing.WindowFn<T, W>.MergeContext)
.
-
-
Constructor Summary
Constructors Constructor and Description MergeContext()
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description abstract void
merge(Collection<W> toBeMerged, W mergeResult)
Signals to the framework that the windows intoBeMerged
should be merged together to formmergeResult
.abstract Collection<W>
windows()
Returns the current set of windows.
-
-
-
Method Detail
-
windows
public abstract Collection<W> windows()
Returns the current set of windows.
-
merge
public abstract void merge(Collection<W> toBeMerged, W mergeResult) throws Exception
Signals to the framework that the windows intoBeMerged
should be merged together to formmergeResult
.toBeMerged
should be a subset ofwindows()
and disjoint from thetoBeMerged
set of previous calls tomerge
.mergeResult
must either not be inwindows()
or be intoBeMerged
.- Throws:
IllegalArgumentException
- if any elements of toBeMerged are not in windows(), or have already been mergedException
-
-