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

Class SparkExecutableStageContextFactory

java.lang.Object

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

All Implemented Interfaces:

Serializable, org.apache.beam.runners.fnexecution.control.ExecutableStageContext.Factory

public class SparkExecutableStageContextFactory
extends Object
implements org.apache.beam.runners.fnexecution.control.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
org.apache.beam.runners.fnexecution.control.ExecutableStageContext	get(org.apache.beam.runners.fnexecution.provisioning.JobInfo 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 org.apache.beam.runners.fnexecution.control.ExecutableStageContext get(org.apache.beam.runners.fnexecution.provisioning.JobInfo jobInfo)

Specified by:

get in interface org.apache.beam.runners.fnexecution.control.ExecutableStageContext.Factory