org.apache.beam.runners.fnexecution.provisioning

Class StaticGrpcProvisionService

java.lang.Object

org.apache.beam.model.fnexecution.v1.ProvisionServiceGrpc.ProvisionServiceImplBase

org.apache.beam.runners.fnexecution.provisioning.StaticGrpcProvisionService

All Implemented Interfaces:

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

public class StaticGrpcProvisionService
extends org.apache.beam.model.fnexecution.v1.ProvisionServiceGrpc.ProvisionServiceImplBase
implements FnService

A provision service that returns a static response to all calls.

Method Summary

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.v1p48p1.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)

Methods inherited from class org.apache.beam.model.fnexecution.v1.ProvisionServiceGrpc.ProvisionServiceImplBase

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.v1p48p1.io.grpc.BindableService

bindService

Method Detail

create

public static StaticGrpcProvisionService create(org.apache.beam.model.fnexecution.v1.ProvisionApi.ProvisionInfo info,
                                                HeaderAccessor headerAccessor)

getProvisionInfo

public void getProvisionInfo(org.apache.beam.model.fnexecution.v1.ProvisionApi.GetProvisionInfoRequest request,
                             org.apache.beam.vendor.grpc.v1p48p1.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.ProvisionApi.GetProvisionInfoResponse> responseObserver)

Overrides:

getProvisionInfo in class org.apache.beam.model.fnexecution.v1.ProvisionServiceGrpc.ProvisionServiceImplBase

close

public void close()
           throws java.lang.Exception

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

Throws:

java.lang.Exception

registerEnvironment

public void registerEnvironment(java.lang.String workerId,
                                org.apache.beam.model.pipeline.v1.RunnerApi.Environment environment)