@ThreadSafe public class StaticRemoteEnvironment extends java.lang.Object implements RemoteEnvironment
RemoteEnvironment
that connects to Dataflow runner harness.RemoteEnvironment.SimpleRemoteEnvironment
Modifier and Type | Method and Description |
---|---|
void |
close()
.
|
org.apache.beam.model.pipeline.v1.RunnerApi.Environment |
getEnvironment()
Return the environment that the remote handles.
|
InstructionRequestHandler |
getInstructionRequestHandler()
Return an
InstructionRequestHandler which can communicate with the environment. |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
forHandler
public org.apache.beam.model.pipeline.v1.RunnerApi.Environment getEnvironment()
RemoteEnvironment
getEnvironment
in interface RemoteEnvironment
public InstructionRequestHandler getInstructionRequestHandler()
RemoteEnvironment
InstructionRequestHandler
which can communicate with the environment.getInstructionRequestHandler
in interface RemoteEnvironment
public void close() throws java.lang.Exception
RemoteEnvironment
By default, closes the RemoteEnvironment.getInstructionRequestHandler()
.
close
in interface java.lang.AutoCloseable
close
in interface RemoteEnvironment
java.lang.Exception