See: Description
| Interface | Description |
|---|---|
| CloseableFnDataReceiver<T> |
A receiver of streamed data that can be closed.
|
| FnDataReceiver<T> |
A receiver of streamed data.
|
| Class | Description |
|---|---|
| BeamFnDataGrpcMultiplexer |
A gRPC multiplexer for a specific
Endpoints.ApiServiceDescriptor. |
| BeamFnDataInboundObserver | |
| BeamFnDataOutboundAggregator |
An outbound data buffering aggregator with size-based buffer and time-based buffer if
corresponding options are set.
|
| 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> | |
| WeightedList<T> |
Facade for a
List that keeps track of weight, for cache limit reasons. |
| Exception | Description |
|---|---|
| BeamFnDataInboundObserver.CloseException |