org.apache.beam.runners.fnexecution

Class ServerFactory

java.lang.Object

org.apache.beam.runners.fnexecution.ServerFactory

Direct Known Subclasses:

InProcessServerFactory, ServerFactory.InetSocketAddressServerFactory

public abstract class ServerFactory
extends java.lang.Object

A gRPC server factory.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	ServerFactory.InetSocketAddressServerFactory Creates a gRPC Server using the default server factory.
static interface	ServerFactory.UrlFactory Factory that constructs client-accessible URLs from a local server address and port.

Constructor Summary

Constructors

Constructor and Description
ServerFactory()

Method Summary

Modifier and Type	Method and Description
abstract org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Server	allocatePortAndCreate(org.apache.beam.vendor.grpc.v1_13_1.io.grpc.BindableService service, org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor.Builder builder) Creates an instance of this server using an ephemeral port chosen automatically.
abstract org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Server	create(org.apache.beam.vendor.grpc.v1_13_1.io.grpc.BindableService service, org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor serviceDescriptor) Creates an instance of this server at the address specified by the given service descriptor.
static ServerFactory	createDefault() Create a default ServerFactory.
static ServerFactory	createWithPortSupplier(java.util.function.Supplier<java.lang.Integer> portSupplier) Create a ServerFactory that uses ports from a supplier.
static ServerFactory	createWithUrlFactory(ServerFactory.UrlFactory urlFactory) Create a ServerFactory that uses the given url factory.
static ServerFactory	createWithUrlFactoryAndPortSupplier(ServerFactory.UrlFactory urlFactory, java.util.function.Supplier<java.lang.Integer> portSupplier) Create a ServerFactory that uses the given url factory and ports from a supplier.

Methods inherited from class java.lang.Object

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

Constructor Detail

ServerFactory

public ServerFactory()

Method Detail

createDefault

public static ServerFactory createDefault()

Create a default ServerFactory.

createWithUrlFactory

public static ServerFactory createWithUrlFactory(ServerFactory.UrlFactory urlFactory)

Create a ServerFactory that uses the given url factory.

createWithPortSupplier

public static ServerFactory createWithPortSupplier(java.util.function.Supplier<java.lang.Integer> portSupplier)

Create a ServerFactory that uses ports from a supplier.

createWithUrlFactoryAndPortSupplier

public static ServerFactory createWithUrlFactoryAndPortSupplier(ServerFactory.UrlFactory urlFactory,
                                                                java.util.function.Supplier<java.lang.Integer> portSupplier)

Create a ServerFactory that uses the given url factory and ports from a supplier.

allocatePortAndCreate

public abstract org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Server allocatePortAndCreate(org.apache.beam.vendor.grpc.v1_13_1.io.grpc.BindableService service,
                                                                                         org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor.Builder builder)
                                                                                  throws java.io.IOException

Creates an instance of this server using an ephemeral port chosen automatically. The chosen port is accessible to the caller from the URL set in the input Endpoints.ApiServiceDescriptor.Builder. Server applies GrpcContextHeaderAccessorProvider.interceptor() to all incoming requests.

Throws:

java.io.IOException

create

public abstract org.apache.beam.vendor.grpc.v1_13_1.io.grpc.Server create(org.apache.beam.vendor.grpc.v1_13_1.io.grpc.BindableService service,
                                                                          org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor serviceDescriptor)
                                                                   throws java.io.IOException

Creates an instance of this server at the address specified by the given service descriptor. Server applies GrpcContextHeaderAccessorProvider.interceptor() to all incoming requests.

Throws:

java.io.IOException