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<T> |
Decodes individually consumed
ByteString s 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 . |
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 . |