org.apache.beam.runners.fnexecution

Class InProcessServerFactory

java.lang.Object

org.apache.beam.runners.fnexecution.ServerFactory

org.apache.beam.runners.fnexecution.InProcessServerFactory

public class InProcessServerFactory
extends ServerFactory

A ServerFactory which creates servers with the InProcessServerBuilder.

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.v1p13p1.io.grpc.Server	allocateAddressAndCreate(java.util.List<org.apache.beam.vendor.grpc.v1p13p1.io.grpc.BindableService> services, org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor.Builder builder) Creates an instance of this server using an ephemeral address.
static InProcessServerFactory	create()
org.apache.beam.vendor.grpc.v1p13p1.io.grpc.Server	create(java.util.List<org.apache.beam.vendor.grpc.v1p13p1.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

create

public static InProcessServerFactory create()

allocateAddressAndCreate

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