[BEAM-13416] SqsIO.write input / construction of Sqs request

• Type: Improvement
• Status: Open
• Priority: P2
• Resolution: Unresolved
• Component/s: io-java-aws
• Labels: aws aws-sdk-v2 sqs
• Assignee: Unassigned
• Reporter: Moritz Mack
• Created: 08/Dec/21 14:44
• Updated: 04/Jun/22 23:23

Description

SqsIO.write should support arbitrary types T and be implemented in terms of a mapper function that converts T into an AWS request.

The current implementation of write as PTransform<PCollection<SendMessageRequest>, PDone> is a rather poor choice. It may requires an additional unnecessary serialization & deserialisation round. But even worse, the current SendMessageRequestCoder does not support any advanced configuration beyond queueUrl and messageBody and will silently drop it without even warning the user.

Issue Links

• links to: GitHub Pull Request #16947