@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 |