Package org.apache.beam.runners.fnexecution.control

Class DefaultJobBundleFactory

java.lang.Object

org.apache.beam.runners.fnexecution.control.DefaultJobBundleFactory

All Implemented Interfaces:

AutoCloseable, JobBundleFactory

@ThreadSafe
public class DefaultJobBundleFactory
extends Object
implements JobBundleFactory

A JobBundleFactory for which the implementation can specify a custom EnvironmentFactory for environment management. Note that returned stage bundle factories are not thread-safe. Instead, a new stage factory should be created for each client. DefaultJobBundleFactory initializes the Environment lazily when the forStage is called for a stage.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DefaultJobBundleFactory.ServerInfo	A container for EnvironmentFactory and its corresponding Grpc servers.
protected static class	DefaultJobBundleFactory.WrappedSdkHarnessClient	Holder for an SdkHarnessClient along with its associated state and data servers.

Method Summary

Modifier and Type	Method	Description
void	close()
static DefaultJobBundleFactory	create(JobInfo jobInfo)
static DefaultJobBundleFactory	create(JobInfo jobInfo, Map<String,EnvironmentFactory.Provider> environmentFactoryProviderMap)
StageBundleFactory	forStage(org.apache.beam.sdk.util.construction.graph.ExecutableStage executableStage)

Methods inherited from class java.lang.Object

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

Method Details

create

public static DefaultJobBundleFactory create(JobInfo jobInfo)

create

public static DefaultJobBundleFactory create(JobInfo jobInfo,
 Map<String,EnvironmentFactory.Provider> environmentFactoryProviderMap)

forStage

public StageBundleFactory forStage(org.apache.beam.sdk.util.construction.graph.ExecutableStage executableStage)

Specified by:

forStage in interface JobBundleFactory

close

public void close()
           throws Exception

Specified by:

close in interface AutoCloseable

Throws:

Exception