Package org.apache.beam.io.requestresponse

Package provides Beam I/O transform support for safely reading from and writing to Web APIs.

See: Description

Interface Summary

Interface	Description
Caller<RequestT,ResponseT>	Caller interfaces user custom code intended for API calls.
CallShouldBackoff<ResponseT>	Informs whether a call to an API should backoff.
SerializableSupplier<T>	A union of a Supplier and Serializable, enabling configuration with T types that are not Serializable.
SetupTeardown	Provided by user and called within DoFn.Setup and @{link org.apache.beam.sdk.transforms.DoFn.Teardown} lifecycle methods of Call's DoFn.

Class Summary

Class	Description
ApiIOError	ApiIOError is a data class for storing details about an error.
Cache	Transforms for reading and writing request/response associations to a cache.
Cache.Pair<RequestT,ResponseT>	A simple POJO that holds both cache read and write PTransforms.
Monitoring	Configures Metrics throughout various features of RequestResponseIO.
Monitoring.Builder
RequestResponseIO<RequestT,ResponseT>	PTransform for reading from and writing to Web APIs.
Result<ResponseT>	The Result of processing request PCollection into response PCollection.

Exception Summary

Exception	Description
UserCodeExecutionException	Base Exception for signaling errors in user custom code.
UserCodeQuotaException	Extends UserCodeQuotaException to allow the user custom code to specifically signal a Quota or API overuse related error.
UserCodeRemoteSystemException	A UserCodeExecutionException that signals an error with a remote system.
UserCodeTimeoutException	An extension of UserCodeQuotaException to specifically signal a user code timeout.

Package org.apache.beam.io.requestresponse Description

Package provides Beam I/O transform support for safely reading from and writing to Web APIs.