Class ProcessEnvironment
java.lang.Object
org.apache.beam.runners.fnexecution.environment.ProcessEnvironment
- All Implemented Interfaces:
AutoCloseable
,RemoteEnvironment
Environment for process-based execution. The environment is responsible for stopping the process.
-
Nested Class Summary
Nested classes/interfaces inherited from interface org.apache.beam.runners.fnexecution.environment.RemoteEnvironment
RemoteEnvironment.SimpleRemoteEnvironment
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
.static RemoteEnvironment
create
(ProcessManager processManager, org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, String workerId, InstructionRequestHandler instructionHandler) org.apache.beam.model.pipeline.v1.RunnerApi.Environment
Return the environment that the remote handles.Return anInstructionRequestHandler
which can communicate with the environment.
-
Method Details
-
create
public static RemoteEnvironment create(ProcessManager processManager, org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment, String workerId, InstructionRequestHandler instructionHandler) -
getEnvironment
public org.apache.beam.model.pipeline.v1.RunnerApi.Environment getEnvironment()Description copied from interface:RemoteEnvironment
Return the environment that the remote handles.- Specified by:
getEnvironment
in interfaceRemoteEnvironment
-
getInstructionRequestHandler
Description copied from interface:RemoteEnvironment
Return anInstructionRequestHandler
which can communicate with the environment.- Specified by:
getInstructionRequestHandler
in interfaceRemoteEnvironment
-
close
Description copied from interface:RemoteEnvironment
.By default, closes the
RemoteEnvironment.getInstructionRequestHandler()
.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceRemoteEnvironment
- Throws:
Exception
-