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