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

Class FlinkExecutableStageContextFactory

java.lang.Object

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

All Implemented Interfaces:

Serializable, ExecutableStageContext.Factory

public class FlinkExecutableStageContextFactory
extends Object
implements ExecutableStageContext.Factory

Singleton class that contains one ExecutableStageContext.Factory per job.

See Also:

• Serialized Form

Method Summary

Modifier and Type	Method	Description
ExecutableStageContext	get(JobInfo jobInfo)	Get or create ExecutableStageContext for given JobInfo.
static FlinkExecutableStageContextFactory	getInstance()

Methods inherited from class java.lang.Object

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

Method Details

getInstance

public static FlinkExecutableStageContextFactory getInstance()

get

public ExecutableStageContext get(JobInfo jobInfo)

Description copied from interface: ExecutableStageContext.Factory

Get or create ExecutableStageContext for given JobInfo.

Specified by:

get in interface ExecutableStageContext.Factory