Package org.apache.beam.runners.flink.translation.functions

Class FlinkNoOpStepContext

java.lang.Object

org.apache.beam.runners.flink.translation.functions.FlinkNoOpStepContext

All Implemented Interfaces:

org.apache.beam.runners.core.StepContext

public class FlinkNoOpStepContext
extends Object
implements org.apache.beam.runners.core.StepContext

A StepContext for Flink Batch Runner execution.

Constructor Summary

Constructors

Constructor	Description
FlinkNoOpStepContext()

Method Summary

Modifier and Type	Method	Description
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

Methods inherited from interface org.apache.beam.runners.core.StepContext

bundleFinalizer

Constructor Details

FlinkNoOpStepContext

public FlinkNoOpStepContext()

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