org.apache.beam.runners.fnexecution.control

Interface ExecutableStageContext.Factory

All Superinterfaces:

java.io.Serializable

All Known Implementing Classes:

ReferenceCountingExecutableStageContextFactory

Enclosing interface:

ExecutableStageContext

public static interface ExecutableStageContext.Factory
extends java.io.Serializable

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

Method Summary

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

Method Detail

get

ExecutableStageContext get(JobInfo jobInfo)

Get or create ExecutableStageContext for given JobInfo.