@Experimental(value=SOURCE_SINK)
See: Description
| Interface | Description |
|---|---|
| SqsClientProvider | Deprecated
Configure a custom
ClientBuilderFactory
using AwsOptions.getClientBuilderFactory() instead. |
| Class | Description |
|---|---|
| MessageCoder |
Custom Coder for handling SendMessageRequest for using in Write.
|
| MessageCoderRegistrar |
A
CoderProviderRegistrar for standard types used with SqsIO. |
| SendMessageRequestCoder |
Custom Coder for handling SendMessageRequest for using in Write.
|
| SendMessageRequestCoderRegistrar |
A
CoderProviderRegistrar for standard types used with SqsIO. |
| SqsIO |
IO to read (unbounded) from and write to SQS queues.
|
| SqsIO.Read |
A
PTransform to read/receive messages from SQS. |
| SqsIO.Write |
A
PTransform to send messages to SQS. |
| SqsMessage |