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

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

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.

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.

Specified by:

create in class ServerFactory

Throws:

java.io.IOException