Package org.apache.beam.runners.fnexecution

Utilities used by runners to interact with the fn execution components of the Beam Portability Framework.

See: Description

Interface Summary

Interface	Description
FnService	An interface sharing common behavior with services used during execution of user Fns.
HeaderAccessor	Interface to access headers in the client request.
ServerFactory.UrlFactory	Factory that constructs client-accessible URLs from a local server address and port.

Class Summary

Class	Description
GrpcContextHeaderAccessorProvider	A HeaderAccessorProvider which intercept the header in a GRPC request and expose the relevant fields.
GrpcFnServer<ServiceT extends FnService>	A gRPC Server which manages a single FnService.
InProcessServerFactory	A ServerFactory which creates servers with the InProcessServerBuilder.
ServerFactory	A gRPC server factory.
ServerFactory.InetSocketAddressServerFactory	Creates a gRPC Server using the default server factory.

Package org.apache.beam.runners.fnexecution Description

Utilities used by runners to interact with the fn execution components of the Beam Portability Framework.