Package 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	Description
static interface	EnvironmentFactory.Provider	Provider for a EnvironmentFactory and ServerFactory for the environment.

Method Summary

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

Method Details

createEnvironment

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

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

Throws:

Exception