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.Constructor and Description |
---|
MultiInstanceFactory(int maxFactories,
SerializableFunction<java.lang.Object,java.lang.Boolean> isReleaseSynchronous) |
Modifier and Type | Method and Description |
---|---|
ExecutableStageContext |
get(JobInfo jobInfo)
Get or create
ExecutableStageContext for given JobInfo . |
public MultiInstanceFactory(int maxFactories, SerializableFunction<java.lang.Object,java.lang.Boolean> isReleaseSynchronous)
public ExecutableStageContext get(JobInfo jobInfo)
ExecutableStageContext.Factory
ExecutableStageContext
for given JobInfo
.get
in interface ExecutableStageContext.Factory