Package org.apache.beam.sdk.fn.server

Interface FnService

All Superinterfaces:
AutoCloseable, org.apache.beam.vendor.grpc.v1p69p0.io.grpc.BindableService
All Known Implementing Classes:
ArtifactRetrievalService, ArtifactStagingService, BeamWorkerStatusGrpcService, FnApiControlClientPoolService, GrpcDataService, GrpcLoggingService, GrpcStateService, InMemoryJobService, StaticGrpcProvisionService
public interface FnService extends AutoCloseable, org.apache.beam.vendor.grpc.v1p69p0.io.grpc.BindableService
An interface sharing common behavior with services used during execution of user Fns.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    close()
    .

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

    bindService

  • Method Details

    • close

      void close() throws Exception
      .

      There should be no more calls to any service method by the time a call to 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
      Throws:
      Exception