Package org.apache.beam.sdk.io.aws2.sqs

package org.apache.beam.sdk.io.aws2.sqs

Defines IO connectors for Amazon Web Services SQS.

Related Packages

Package	Description
org.apache.beam.sdk.io.aws2.sqs.providers	Defines external schema transformation providers for Amazon Web Services SQS.

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.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.
SqsIO.WriteBatches.Result	Result of SqsIO.writeBatches().
SqsMessage