org.apache.beam.runners.fnexecution.environment

Interface EnvironmentFactory

All Known Implementing Classes:

DockerEnvironmentFactory, EmbeddedEnvironmentFactory, ExternalEnvironmentFactory, ProcessEnvironmentFactory, StaticRemoteEnvironmentFactory

public interface EnvironmentFactory

Creates environments which communicate to an SdkHarnessClient.

Nested Class Summary

Nested Classes

Modifier and Type	Interface and Description
static interface	EnvironmentFactory.Provider Provider for a EnvironmentFactory and ServerFactory for the environment.

Method Summary

Modifier and Type	Method and Description
RemoteEnvironment	createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, java.lang.String workerId) Creates an active RunnerApi.Environment and returns a handle to it.

Method Detail

createEnvironment

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

Creates an active RunnerApi.Environment and returns a handle to it.

Throws:

java.lang.Exception