public interface EnvironmentFactory
environments
which communicate to an SdkHarnessClient
.Modifier and Type | Interface and Description |
---|---|
static interface |
EnvironmentFactory.Provider
Provider for a
EnvironmentFactory and ServerFactory for the environment. |
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. |
RemoteEnvironment createEnvironment(org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, java.lang.String workerId) throws java.lang.Exception
RunnerApi.Environment
and returns a handle to it.java.lang.Exception