public interface FnDataService
FnDataServiceis able to forward inbound elements to a consumer and is also a consumer of outbound elements. Callers can register themselves as consumers for inbound elements or can get a handle for a consumer for outbound elements.
|Modifier and Type||Method and Description|
Registers a receiver to be notified upon any incoming elements.
Creates a receiver to which you can write data values and have them sent over this data plane service.
<T> InboundDataClient receive(LogicalEndpoint inputLocation, Coder<org.apache.beam.sdk.util.WindowedValue<T>> coder, FnDataReceiver<org.apache.beam.sdk.util.WindowedValue<T>> listener)
The provided coder is used to decode inbound elements. The decoded elements are passed to the provided receiver.
The provided receiver is not required to be thread safe.
<T> CloseableFnDataReceiver<org.apache.beam.sdk.util.WindowedValue<T>> send(LogicalEndpoint outputLocation, Coder<org.apache.beam.sdk.util.WindowedValue<T>> coder)
The provided coder is used to encode elements on the outbound stream.
Closing the returned receiver signals the end of the stream.
The returned receiver is not thread safe.