See: Description
| Interface | Description |
|---|---|
| BeamFnDataBufferingOutboundObserver<T> |
A buffering outbound
FnDataReceiver for the Beam Fn Data API. |
| CloseableFnDataReceiver<T> |
A receiver of streamed data that can be closed.
|
| FnDataReceiver<T> |
A receiver of streamed data.
|
| InboundDataClient |
A client representing some stream of inbound data.
|
| Class | Description |
|---|---|
| BeamFnDataGrpcMultiplexer |
A gRPC multiplexer for a specific
Endpoints.ApiServiceDescriptor. |
| BeamFnDataInboundObserver |
Decodes individually consumed
ByteStrings with the provided Coder passing the
individual decoded elements to the provided consumer. |
| BeamFnDataSizeBasedBufferingOutboundObserver<T> |
A size-based buffering outbound
FnDataReceiver for the Beam Fn Data API. |
| BeamFnDataTimeBasedBufferingOutboundObserver<T> |
A buffering outbound
FnDataReceiver with both size-based buffer and time-based buffer
enabled for the Beam Fn Data API. |
| CompletableFutureInboundDataClient |
An
InboundDataClient backed by a CompletableFuture. |
| DecodingFnDataReceiver<T> |
A receiver of encoded data, decoding it and passing it onto a downstream consumer.
|
| LogicalEndpoint |
A logical endpoint is a pair of an instruction ID corresponding to the
BeamFnApi.ProcessBundleRequest and the transform within the processing graph. |
| RemoteGrpcPortRead |
An execution-time only
RunnerApi.PTransform which represents an SDK harness reading from a BeamFnApi.RemoteGrpcPort. |
| RemoteGrpcPortWrite |
An execution-time only
RunnerApi.PTransform which represents a write from within an SDK harness to
a BeamFnApi.RemoteGrpcPort. |