Package org.apache.beam.runners.fnexecution.control

Interface ExecutableStageContext.Factory

All Superinterfaces:

Serializable

All Known Implementing Classes:

FlinkExecutableStageContextFactory, ReferenceCountingExecutableStageContextFactory, SparkExecutableStageContextFactory

Enclosing interface:

ExecutableStageContext

public static interface ExecutableStageContext.Factory
extends Serializable

Creates ExecutableStageContext instances. Serializable so that factories can be defined at translation time and distributed to TaskManagers.

Method Summary

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

Method Details

get

ExecutableStageContext get(JobInfo jobInfo)

Get or create ExecutableStageContext for given JobInfo.