Package org.apache.beam.io.requestresponse

package org.apache.beam.io.requestresponse

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

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.
Caller<RequestT,ResponseT>	Caller interfaces user custom code intended for API calls.
CallShouldBackoff<ResponseT>	Informs whether a call to an API should backoff.
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.
SetupTeardown	Provided by user and called within DoFn.Setup and @{link org.apache.beam.sdk.transforms.DoFn.Teardown} lifecycle methods of Call's DoFn.
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.