org.apache.beam.runners.fnexecution.control

Class DefaultExecutableStageContext.MultiInstanceFactory

java.lang.Object

org.apache.beam.runners.fnexecution.control.DefaultExecutableStageContext.MultiInstanceFactory

All Implemented Interfaces:

java.io.Serializable, ExecutableStageContext.Factory

Enclosing class:

DefaultExecutableStageContext

public static class DefaultExecutableStageContext.MultiInstanceFactory
extends java.lang.Object
implements ExecutableStageContext.Factory

ExecutableStageContext.Factory that creates and round-robins between a number of child ExecutableStageContext.Factory instances.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
MultiInstanceFactory(int maxFactories, SerializableFunction<java.lang.Object,java.lang.Boolean> isReleaseSynchronous)

Method Summary

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

Methods inherited from class java.lang.Object

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

Constructor Detail

MultiInstanceFactory

public MultiInstanceFactory(int maxFactories,
                            SerializableFunction<java.lang.Object,java.lang.Boolean> isReleaseSynchronous)

Method Detail

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