org.apache.beam.runners.fnexecution.environment

Interface EnvironmentManager

public interface EnvironmentManager

Manages access to environments which communicate to an SdkHarnessClient.

Method Summary

Modifier and Type	Method and Description
org.apache.beam.runners.fnexecution.environment.RemoteEnvironment	getEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment container) Retrieve a handle to an active RunnerApi.Environment.

Method Detail

getEnvironment

org.apache.beam.runners.fnexecution.environment.RemoteEnvironment getEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment container)
                                                                          throws java.lang.Exception

Retrieve a handle to an active RunnerApi.Environment. This may allocate resources if required.

TODO: Determine and document the owner of the returned environment. If the environment is owned by the manager, make the Manager AutoCloseable..

Throws:

java.lang.Exception