public class DockerEnvironmentFactory extends java.lang.Object implements EnvironmentFactory
EnvironmentFactory
that creates docker containers by shelling out to docker. Returned
RemoteEnvironments
own their respective docker containers. Not
thread-safe.Modifier and Type | Class and Description |
---|---|
static class |
DockerEnvironmentFactory.Provider
Provider for DockerEnvironmentFactory.
|
Modifier and Type | Method and Description |
---|---|
RemoteEnvironment |
createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment,
java.lang.String workerId)
Creates a new, active
RemoteEnvironment backed by a local Docker container. |
public RemoteEnvironment createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, java.lang.String workerId) throws java.lang.Exception
RemoteEnvironment
backed by a local Docker container.createEnvironment
in interface EnvironmentFactory
java.lang.Exception