org.apache.beam.runners.portability

Class ExternalWorkerService

java.lang.Object

org.apache.beam.model.fnexecution.v1.BeamFnExternalWorkerPoolGrpc.BeamFnExternalWorkerPoolImplBase

org.apache.beam.runners.portability.ExternalWorkerService

All Implemented Interfaces:

java.lang.AutoCloseable, FnService, org.apache.beam.vendor.grpc.v1p36p0.io.grpc.BindableService

public class ExternalWorkerService
extends org.apache.beam.model.fnexecution.v1.BeamFnExternalWorkerPoolGrpc.BeamFnExternalWorkerPoolImplBase
implements FnService

Implements the BeamFnExternalWorkerPool service by starting a fresh SDK harness for each request.

Constructor Summary

Constructors

Constructor and Description
ExternalWorkerService(PipelineOptions options)

Method Summary

Modifier and Type	Method and Description
void	close() .
GrpcFnServer<ExternalWorkerService>	start()
void	startWorker(org.apache.beam.model.fnexecution.v1.BeamFnApi.StartWorkerRequest request, org.apache.beam.vendor.grpc.v1p36p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StartWorkerResponse> responseObserver)
void	stopWorker(org.apache.beam.model.fnexecution.v1.BeamFnApi.StopWorkerRequest request, org.apache.beam.vendor.grpc.v1p36p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StopWorkerResponse> responseObserver)

Methods inherited from class org.apache.beam.model.fnexecution.v1.BeamFnExternalWorkerPoolGrpc.BeamFnExternalWorkerPoolImplBase

bindService

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface org.apache.beam.vendor.grpc.v1p36p0.io.grpc.BindableService

bindService

Constructor Detail

ExternalWorkerService

public ExternalWorkerService(PipelineOptions options)

Method Detail

startWorker

public void startWorker(org.apache.beam.model.fnexecution.v1.BeamFnApi.StartWorkerRequest request,
                        org.apache.beam.vendor.grpc.v1p36p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StartWorkerResponse> responseObserver)

Overrides:

startWorker in class org.apache.beam.model.fnexecution.v1.BeamFnExternalWorkerPoolGrpc.BeamFnExternalWorkerPoolImplBase

stopWorker

public void stopWorker(org.apache.beam.model.fnexecution.v1.BeamFnApi.StopWorkerRequest request,
                       org.apache.beam.vendor.grpc.v1p36p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.BeamFnApi.StopWorkerResponse> responseObserver)

Overrides:

stopWorker in class org.apache.beam.model.fnexecution.v1.BeamFnExternalWorkerPoolGrpc.BeamFnExternalWorkerPoolImplBase

close

public void close()

Description copied from interface: FnService

.

There should be no more calls to any service method by the time a call to FnService.close() begins. Specifically, this means that a Server that this service is bound to should have completed a call to the Server.shutdown() method, and all future incoming calls will be rejected.

Specified by:

close in interface java.lang.AutoCloseable

Specified by:

close in interface FnService

start

public GrpcFnServer<ExternalWorkerService> start()
                                          throws java.lang.Exception

Throws:

java.lang.Exception