org.apache.beam.runners.fnexecution

Class ServerFactory.InetSocketAddressServerFactory

java.lang.Object

org.apache.beam.runners.fnexecution.ServerFactory

org.apache.beam.runners.fnexecution.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".

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.beam.runners.fnexecution.ServerFactory

ServerFactory.InetSocketAddressServerFactory, ServerFactory.UrlFactory

Method Summary

Modifier and Type	Method and Description
org.apache.beam.vendor.grpc.v1p21p0.io.grpc.Server	allocateAddressAndCreate(java.util.List<org.apache.beam.vendor.grpc.v1p21p0.io.grpc.BindableService> services, org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor.Builder apiServiceDescriptor) Creates an instance of this server using an ephemeral address.
org.apache.beam.vendor.grpc.v1p21p0.io.grpc.Server	create(java.util.List<org.apache.beam.vendor.grpc.v1p21p0.io.grpc.BindableService> services, org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor serviceDescriptor) Creates an instance of this server at the address specified by the given service descriptor and bound to multiple services.

Methods inherited from class org.apache.beam.runners.fnexecution.ServerFactory

createDefault, createEpollDomainSocket, createEpollSocket, createWithPortSupplier, createWithUrlFactory, createWithUrlFactoryAndPortSupplier

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

allocateAddressAndCreate

public org.apache.beam.vendor.grpc.v1p21p0.io.grpc.Server allocateAddressAndCreate(java.util.List<org.apache.beam.vendor.grpc.v1p21p0.io.grpc.BindableService> services,
                                                                                   org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor.Builder apiServiceDescriptor)
                                                                            throws java.io.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:

java.io.IOException

create

public org.apache.beam.vendor.grpc.v1p21p0.io.grpc.Server create(java.util.List<org.apache.beam.vendor.grpc.v1p21p0.io.grpc.BindableService> services,
                                                                 org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor serviceDescriptor)
                                                          throws java.io.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:

java.io.IOException