com.google.cloud.dataflow.sdk.util

Class ReduceFn.OnMergeContext

java.lang.Object

com.google.cloud.dataflow.sdk.util.ReduceFn.Context

com.google.cloud.dataflow.sdk.util.ReduceFn.OnMergeContext

Enclosing class:

ReduceFn<K,InputT,OutputT,W extends BoundedWindow>

public abstract class ReduceFn.OnMergeContext
extends ReduceFn.Context

Information accessible within ReduceFn.onMerge(com.google.cloud.dataflow.sdk.util.ReduceFn<K, InputT, OutputT, W>.OnMergeContext).

Constructor Summary

Constructors

Constructor and Description
OnMergeContext()

Method Summary

Modifier and Type	Method and Description
abstract Collection<W>	mergingWindows() Return the collection of windows that were merged.
abstract ReduceFn.MergingStateContext	state() Return the interface for accessing state.

Methods inherited from class com.google.cloud.dataflow.sdk.util.ReduceFn.Context

key, timers, window, windowingStrategy

Methods inherited from class java.lang.Object

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

Constructor Detail

OnMergeContext

public OnMergeContext()

Method Detail

mergingWindows

public abstract Collection<W> mergingWindows()

Return the collection of windows that were merged.

Note that this may include the result window.

state

public abstract ReduceFn.MergingStateContext state()

Return the interface for accessing state.

Specified by:

state in class ReduceFn.Context