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 | Deprecated
Migrate to
BeamFnDataInboundObserver2. |
| Class | Description |
|---|---|
| BeamFnDataGrpcMultiplexer | Deprecated
Migrate to
BeamFnDataGrpcMultiplexer2. |
| BeamFnDataGrpcMultiplexer2 |
A gRPC multiplexer for a specific
Endpoints.ApiServiceDescriptor. |
| BeamFnDataInboundObserver | Deprecated
Migrate to
BeamFnDataInboundObserver2. |
| BeamFnDataInboundObserver2 | |
| 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. |
| DataEndpoint<T> | |
| 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. |
| TimerEndpoint<T> |