Package 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:
AutoCloseable, org.apache.beam.model.fnexecution.v1.ProvisionServiceGrpc.AsyncService, FnService, org.apache.beam.vendor.grpc.v1p69p0.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
    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.v1p69p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.ProvisionApi.GetProvisionInfoResponse> responseObserver)
     
    void
    registerEnvironment(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.v1p69p0.io.grpc.BindableService

    bindService

  • Method Details

    • 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.v1p69p0.io.grpc.stub.StreamObserver<org.apache.beam.model.fnexecution.v1.ProvisionApi.GetProvisionInfoResponse> responseObserver)
      Specified by:
      getProvisionInfo in interface org.apache.beam.model.fnexecution.v1.ProvisionServiceGrpc.AsyncService

    • close

      public void close() throws 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 AutoCloseable
      Specified by:
      close in interface FnService
      Throws:
      Exception

    • registerEnvironment

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