org.apache.beam.sdk.state

Interface StateContext<W extends BoundedWindow>

@Internal
public interface StateContext<W extends BoundedWindow>

For internal use only; no backwards-compatibility guarantees.

Method Summary

Modifier and Type	Method and Description
PipelineOptions	getPipelineOptions() Returns the PipelineOptions specified with the PipelineRunner.
<T> T	sideInput(PCollectionView<T> view) Returns the value of the side input for the corresponding state window.
W	window() Returns the window corresponding to the state.

Method Detail

getPipelineOptions

PipelineOptions getPipelineOptions()

Returns the PipelineOptions specified with the PipelineRunner.

sideInput

<T> T sideInput(PCollectionView<T> view)

Returns the value of the side input for the corresponding state window.

window

W window()

Returns the window corresponding to the state.