@Experimental(value=SOURCE_SINK)
See: Description
| Interface | Description |
|---|---|
| SqsClientProvider |
Provides instances of Sqs clients.
|
| 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 |
An unbounded source for Amazon Simple Queue Service (SQS).
|
| SqsIO.Read |
A
PTransform to read/receive messages from SQS. |
| SqsIO.Write |
A
PTransform to send messages to SQS. |
| SqsMessage |