com.google.cloud.dataflow.sdk.util

Interface ReduceFn.StateContext

All Known Subinterfaces:

ReduceFn.MergingStateContext

Enclosing class:

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

public static interface ReduceFn.StateContext

Interface for interacting with persistent state.

Method Summary

Modifier and Type	Method and Description
<StateT extends State> StateT	access(StateTag<StateT> address) Access the storage for the given address in the current window.
<StateT extends MergeableState<?,?>> StateT	accessAcrossMergedWindows(StateTag<StateT> address) Access the storage for the given address in all of the windows that were merged into the current window including the current window.

Method Detail

access

<StateT extends State> StateT access(StateTag<StateT> address)

Access the storage for the given address in the current window.

accessAcrossMergedWindows

<StateT extends MergeableState<?,?>> StateT accessAcrossMergedWindows(StateTag<StateT> address)

Access the storage for the given address in all of the windows that were merged into the current window including the current window.

If no windows were merged, this reads from just the current window.