org.apache.beam.runners.fnexecution.control

Class ReferenceCountingExecutableStageContextFactory

java.lang.Object

org.apache.beam.runners.fnexecution.control.ReferenceCountingExecutableStageContextFactory

All Implemented Interfaces:

java.io.Serializable, ExecutableStageContext.Factory

public class ReferenceCountingExecutableStageContextFactory
extends java.lang.Object
implements ExecutableStageContext.Factory

ExecutableStageContext.Factory which counts ExecutableStageContext reference for book keeping.

See Also:

Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static interface	ReferenceCountingExecutableStageContextFactory.Creator Interface for creator which extends Serializable.

Method Summary

Modifier and Type	Method and Description
static ReferenceCountingExecutableStageContextFactory	create(ReferenceCountingExecutableStageContextFactory.Creator creator, SerializableFunction<java.lang.Object,java.lang.Boolean> isReleaseSynchronous)
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

Method Detail

create

public static ReferenceCountingExecutableStageContextFactory create(ReferenceCountingExecutableStageContextFactory.Creator creator,
                                                                    SerializableFunction<java.lang.Object,java.lang.Boolean> isReleaseSynchronous)

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