Package org.apache.beam.sdk.fn.server
Class InProcessServerFactory
java.lang.Object
org.apache.beam.sdk.fn.server.ServerFactory
org.apache.beam.sdk.fn.server.InProcessServerFactory
-
Nested Class Summary
Nested classes/interfaces inherited from class org.apache.beam.sdk.fn.server.ServerFactory
ServerFactory.InetSocketAddressServerFactory, ServerFactory.UrlFactory
-
Method Summary
Modifier and TypeMethodDescriptionorg.apache.beam.vendor.grpc.v1p69p0.io.grpc.Server
allocateAddressAndCreate
(List<org.apache.beam.vendor.grpc.v1p69p0.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.v1p69p0.io.grpc.Server
create
(List<org.apache.beam.vendor.grpc.v1p69p0.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.sdk.fn.server.ServerFactory
createDefault, createEpollDomainSocket, createEpollSocket, createWithPortSupplier, createWithUrlFactory, createWithUrlFactoryAndPortSupplier
-
Method Details
-
create
-
allocateAddressAndCreate
public org.apache.beam.vendor.grpc.v1p69p0.io.grpc.Server allocateAddressAndCreate(List<org.apache.beam.vendor.grpc.v1p69p0.io.grpc.BindableService> services, org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor.Builder builder) throws 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 inputEndpoints.ApiServiceDescriptor.Builder
. Server appliesGrpcContextHeaderAccessorProvider.interceptor()
to all incoming requests.- Specified by:
allocateAddressAndCreate
in classServerFactory
- Throws:
IOException
-
create
public org.apache.beam.vendor.grpc.v1p69p0.io.grpc.Server create(List<org.apache.beam.vendor.grpc.v1p69p0.io.grpc.BindableService> services, org.apache.beam.model.pipeline.v1.Endpoints.ApiServiceDescriptor serviceDescriptor) throws 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 appliesGrpcContextHeaderAccessorProvider.interceptor()
to all incoming requests.- Specified by:
create
in classServerFactory
- Throws:
IOException
-