Moritz Mack created BEAM-13416:
----------------------------------
Summary: SqsIO.write
Key: BEAM-13416
URL: https://issues.apache.org/jira/browse/BEAM-13416
Project: Beam
Issue Type: Bug
Components: io-java-aws
Reporter: Moritz Mack
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.
--
This message was sent by Atlassian Jira
(v8.20.1#820001)
