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
io.grpc.Server	allocatePortAndCreate(io.grpc.BindableService service, org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor.Builder apiServiceDescriptor) Creates an instance of this server using an ephemeral port chosen automatically.
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

allocatePortAndCreate

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