Package 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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description PipelineOptions
getPipelineOptions()
Returns thePipelineOptions
specified with thePipelineRunner
.<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 thePipelineOptions
specified with thePipelineRunner
.
-
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.
-
-