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
io.grpc.Server	allocatePortAndCreate(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.
static InProcessServerFactory	create()
io.grpc.Server	create(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.

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

createDefault, createWithUrlFactory

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()

allocatePortAndCreate

public io.grpc.Server allocatePortAndCreate(io.grpc.BindableService service,
                                            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 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.

Specified by:

allocatePortAndCreate in class ServerFactory

Throws:

java.io.IOException

create

public io.grpc.Server create(io.grpc.BindableService service,
                             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. Server applies GrpcContextHeaderAccessorProvider.interceptor() to all incoming requests.

Specified by:

create in class ServerFactory

Throws:

java.io.IOException