@ThreadSafe public class DefaultJobBundleFactory extends java.lang.Object implements JobBundleFactory
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.Modifier and Type | Class and 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. |
Modifier and Type | Method and Description |
---|---|
void |
close() |
static DefaultJobBundleFactory |
create(JobInfo jobInfo) |
static DefaultJobBundleFactory |
create(JobInfo jobInfo,
java.util.Map<java.lang.String,EnvironmentFactory.Provider> environmentFactoryProviderMap) |
StageBundleFactory |
forStage(org.apache.beam.runners.core.construction.graph.ExecutableStage executableStage) |
public static DefaultJobBundleFactory create(JobInfo jobInfo)
public static DefaultJobBundleFactory create(JobInfo jobInfo, java.util.Map<java.lang.String,EnvironmentFactory.Provider> environmentFactoryProviderMap)
public StageBundleFactory forStage(org.apache.beam.runners.core.construction.graph.ExecutableStage executableStage)
forStage
in interface JobBundleFactory
public void close() throws java.lang.Exception
close
in interface java.lang.AutoCloseable
java.lang.Exception