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

Class ServerFactory.InetSocketAddressServerFactory

java.lang.Object
org.apache.beam.sdk.fn.server.ServerFactory
org.apache.beam.sdk.fn.server.ServerFactory.InetSocketAddressServerFactory
Enclosing class:
ServerFactory
public static class ServerFactory.InetSocketAddressServerFactory extends ServerFactory
Creates a gRPC Server using the default server factory.

The server is created listening any open port on "localhost".

  • Method Details

    • allocateAddressAndCreate

      public org.apache.beam.vendor.grpc.v1p69p0.io.grpc.Server allocateAddressAndCreate(List<org.apache.beam.vendor.grpc.v1p69p0.io.grpc.BindableService> services, org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor.Builder apiServiceDescriptor) throws IOException
      Description copied from class: ServerFactory
      Creates an instance of this server using an ephemeral address. The allocation of the address is server type dependent, which means the address may be a port for certain type of server, or a file path for other certain types. The chosen address is accessible to the caller from the URL set in the input Endpoints.ApiServiceDescriptor.Builder. Server applies GrpcContextHeaderAccessorProvider.interceptor() to all incoming requests.
      Specified by:
      allocateAddressAndCreate in class ServerFactory
      Throws:
      IOException

    • create

      public org.apache.beam.vendor.grpc.v1p69p0.io.grpc.Server create(List<org.apache.beam.vendor.grpc.v1p69p0.io.grpc.BindableService> services, org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor serviceDescriptor) throws IOException
      Description copied from class: ServerFactory
      Creates an instance of this server at the address specified by the given service descriptor and bound to multiple services. Server applies GrpcContextHeaderAccessorProvider.interceptor() to all incoming requests.
      Specified by:
      create in class ServerFactory
      Throws:
      IOException