Package org.apache.beam.runners.fnexecution.environment

Class DockerEnvironmentFactory

java.lang.Object

org.apache.beam.runners.fnexecution.environment.DockerEnvironmentFactory

All Implemented Interfaces:

EnvironmentFactory

public class DockerEnvironmentFactory
extends Object
implements EnvironmentFactory

An EnvironmentFactory that creates docker containers by shelling out to docker. Returned RemoteEnvironments own their respective docker containers. Not thread-safe.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DockerEnvironmentFactory.Provider	Provider for DockerEnvironmentFactory.

Method Summary

Modifier and Type	Method	Description
RemoteEnvironment	createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, String workerId)	Creates a new, active RemoteEnvironment backed by a local Docker container.

Methods inherited from class java.lang.Object

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

Method Details

createEnvironment

public RemoteEnvironment createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment,
 String workerId)
                                    throws Exception

Creates a new, active RemoteEnvironment backed by a local Docker container.

Specified by:

createEnvironment in interface EnvironmentFactory

Throws:

Exception