Package org.apache.beam.sdk.fn.data

package org.apache.beam.sdk.fn.data

Classes to interact with the portability framework data plane.

Related Packages

Package	Description
org.apache.beam.sdk.fn	The top level package for the Fn Execution Java libraries.

Class	Description
BeamFnDataGrpcMultiplexer	A gRPC multiplexer for a specific Endpoints.ApiServiceDescriptor.
BeamFnDataInboundObserver	Decodes BeamFnApi.Elements partitioning them using the provided DataEndpoints and TimerEndpoints.
BeamFnDataInboundObserver.CloseException
BeamFnDataOutboundAggregator	An outbound data buffering aggregator with size-based buffer and time-based buffer if corresponding options are set.
CloseableFnDataReceiver<T>	A receiver of streamed data that can be closed.
DataEndpoint<T>
DecodingFnDataReceiver<T>	A receiver of encoded data, decoding it and passing it onto a downstream consumer.
FnDataReceiver<T>	A receiver of streamed data.
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<T> that keeps track of weight, for cache limit reasons.