See: Description
| Interface | Description |
|---|---|
| SqsIO.WriteBatches.DynamicDestination<T> | |
| SqsIO.WriteBatches.EntryMapperFn<T> |
Mapper to create a
SendMessageBatchRequestEntry from a unique batch entry id and the
input T. |
| SqsIO.WriteBatches.EntryMapperFn.Builder<T> |
A more convenient
SqsIO.WriteBatches.EntryMapperFn variant that already sets the entry id. |
| Class | Description |
|---|---|
| SqsIO |
IO to read (unbounded) from and write to SQS queues.
|
| SqsIO.Read |
A
PTransform to read/receive messages from SQS. |
| SqsIO.Write | Deprecated
superseded by
SqsIO.WriteBatches |
| SqsIO.WriteBatches<T> |
A
PTransform to send messages to SQS. |
| SqsIO.WriteBatches.Result |
Result of
SqsIO.writeBatches(). |
| SqsMessage |