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 Details

    • 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.