Package org.apache.beam.runners.flink.translation.wrappers.streaming

Class DoFnOperator.FlinkStepContext

java.lang.Object

org.apache.beam.runners.flink.translation.wrappers.streaming.DoFnOperator.FlinkStepContext

All Implemented Interfaces:

org.apache.beam.runners.core.StepContext

Enclosing class:

DoFnOperator<PreInputT,InputT,OutputT>

protected class DoFnOperator.FlinkStepContext
extends Object
implements org.apache.beam.runners.core.StepContext

StepContext for running DoFns on Flink. This does not allow accessing state or timer internals.

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	FlinkStepContext()

Method Summary

Modifier and Type	Method	Description
DoFn.BundleFinalizer	bundleFinalizer()
org.apache.beam.runners.core.StateInternals	stateInternals()
org.apache.beam.runners.core.TimerInternals	timerInternals()

Methods inherited from class java.lang.Object

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

Constructor Details

FlinkStepContext

protected FlinkStepContext()

Method Details

stateInternals

public org.apache.beam.runners.core.StateInternals stateInternals()

Specified by:

stateInternals in interface org.apache.beam.runners.core.StepContext

timerInternals

public org.apache.beam.runners.core.TimerInternals timerInternals()

Specified by:

timerInternals in interface org.apache.beam.runners.core.StepContext

bundleFinalizer

public DoFn.BundleFinalizer bundleFinalizer()

Specified by:

bundleFinalizer in interface org.apache.beam.runners.core.StepContext