com.google.cloud.dataflow.sdk.util

Class ReduceFn.Context

java.lang.Object

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

Direct Known Subclasses:

ReduceFn.OnMergeContext, ReduceFn.OnTriggerContext, ReduceFn.ProcessValueContext

Enclosing class:

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

public abstract class ReduceFn.Context
extends Object

Information accessible to all the processing methods in this ReduceFn.

Constructor Summary

Constructors

Constructor and Description
Context()

Method Summary

Modifier and Type	Method and Description
abstract K	key() Return the key that is being processed.
abstract ReduceFn.StateContext	state() Return the interface for accessing state.
abstract ReduceFn.Timers	timers() Return the interface for accessing timers.
abstract W	window() The window that is being processed.
abstract WindowingStrategy<?,W>	windowingStrategy() Access the current WindowingStrategy.

Methods inherited from class java.lang.Object

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

Constructor Detail

Context

public Context()

Method Detail

key

public abstract K key()

Return the key that is being processed.

window

public abstract W window()

The window that is being processed.

windowingStrategy

public abstract WindowingStrategy<?,W> windowingStrategy()

Access the current WindowingStrategy.

state

public abstract ReduceFn.StateContext state()

Return the interface for accessing state.

timers

public abstract ReduceFn.Timers timers()

Return the interface for accessing timers.