This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from 1838347 [BEAM-13616] Update com.google.cloud:libraries-bom to 24.2.0
(#16509)
add db28e19 [BEAM-13631] Add deterministic SQS message coder to fix
reading from SQS in batch mode
add 5187008 Merge pull request #16480: [BEAM-13631] Add deterministic SQS
message coder to fix reading from SQS in batch mode (AWS Sdk v1)
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/beam/sdk/io/aws/sqs/SqsIO.java | 24 ++++++-
.../beam/sdk/io/aws/sqs/SqsMessageCoder.java | 82 ++++++++++++++++++++++
.../beam/sdk/io/aws/sqs/SqsUnboundedReader.java | 38 ++++------
.../beam/sdk/io/aws/sqs/SqsUnboundedSource.java | 9 ++-
.../beam/sdk/io/aws/sqs/SqsMessageCoderTest.java | 62 ++++++++++++++++
.../sdk/io/aws/sqs/SqsUnboundedReaderTest.java | 6 +-
.../sdk/io/aws/sqs/SqsUnboundedSourceTest.java | 3 +-
7 files changed, 192 insertions(+), 32 deletions(-)
create mode 100644
sdks/java/io/amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs/SqsMessageCoder.java
create mode 100644
sdks/java/io/amazon-web-services/src/test/java/org/apache/beam/sdk/io/aws/sqs/SqsMessageCoderTest.java
