Package org.apache.beam.runners.fnexecution.data

package org.apache.beam.runners.fnexecution.data

Utilities for a Beam runner to interact with the Fn API Data Service via java abstractions.

Class	Description
FnDataService	The FnDataService is able to forward inbound elements to a consumer and is also a consumer of outbound elements.
GrpcDataService	A FnDataService implemented via gRPC.
RemoteInputDestination<T>	A pair of Coder and invalid reference BeamFnApi.Target which specifies the arguments to a FnDataService to send data to a remote harness.