@Experimental(value=SOURCE_SINK) public class SqsIO extends java.lang.Object
PCollection<SqsMessage> output = pipeline.apply(SqsIO.read().withQueueUrl(queueUrl))
Note: Currently this source does not advance watermarks when no new messages are received.
PCollection<SendMessageRequest> data = ...; data.apply(SqsIO.write())
Configuration for a specific IO can be overwritten using
which also allows to configure the retry behavior for the respective IO.
Retries for failed requests can be configured using
ClientConfiguration.Builder#retry(Consumer) and are handled by the AWS SDK unless there's a
partial success (batch requests). The SDK uses a backoff strategy with equal jitter for computing
the delay before the next retry.
Note: Once retries are exhausted the error is surfaced to the runner which may then opt to retry the current partition in entirety or abort if the max number of retries of the runner is reached.
|Modifier and Type||Class and Description|