public class StaticGrpcProvisionService extends org.apache.beam.model.fnexecution.v1.ProvisionServiceGrpc.ProvisionServiceImplBase implements FnService
provision service
that returns a static response to all calls.Modifier and Type | Method and Description |
---|---|
void |
close()
.
|
static StaticGrpcProvisionService |
create(org.apache.beam.model.fnexecution.v1.ProvisionApi.ProvisionInfo info,
HeaderAccessor headerAccessor) |
void |
getProvisionInfo(org.apache.beam.model.fnexecution.v1.ProvisionApi.GetProvisionInfoRequest request,
org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.ProvisionApi.GetProvisionInfoResponse> responseObserver) |
void |
registerEnvironment(java.lang.String workerId,
org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment) |
bindService
public static StaticGrpcProvisionService create(org.apache.beam.model.fnexecution.v1.ProvisionApi.ProvisionInfo info, HeaderAccessor headerAccessor)
public void getProvisionInfo(org.apache.beam.model.fnexecution.v1.ProvisionApi.GetProvisionInfoRequest request, org.apache.beam.vendor.grpc.v1p26p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.ProvisionApi.GetProvisionInfoResponse> responseObserver)
getProvisionInfo
in class org.apache.beam.model.fnexecution.v1.ProvisionServiceGrpc.ProvisionServiceImplBase
public void close() throws java.lang.Exception
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.
public void registerEnvironment(java.lang.String workerId, org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment)