Package org.apache.beam.runners.spark.translation

Class SparkExecutableStageContextFactory

java.lang.Object

org.apache.beam.runners.spark.translation.SparkExecutableStageContextFactory

All Implemented Interfaces:

Serializable, ExecutableStageContext.Factory

public class SparkExecutableStageContextFactory
extends Object
implements ExecutableStageContext.Factory

Singleton class that contains one ExecutableStageContext.Factory per job. Assumes it is safe to release the backing environment asynchronously.

See Also:

• Serialized Form

Method Summary

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

Methods inherited from class java.lang.Object

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

Method Details

getInstance

public static SparkExecutableStageContextFactory 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