[AWS Sqs] Add SqsIO.writeBatches for improved performance (closes apa…

…che#21429) (apache#26946)
aleksandr-dudko · Jul 17, 2023 · 38d0a87 · 38d0a87
1 parent 0b2fdf2
commit 38d0a87
Show file tree

Hide file tree

Showing 9 changed files with 1,469 additions and 494 deletions.
diff --git a/...eb-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/AsyncBatchWriteHandler.java b/...eb-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/AsyncBatchWriteHandler.java
diff --git a/...n-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientConfiguration.java b/...n-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/common/ClientConfiguration.java
@@ -52,6 +52,7 @@
 @JsonInclude(value = JsonInclude.Include.NON_EMPTY)
 @JsonDeserialize(builder = ClientConfiguration.Builder.class)
 public abstract class ClientConfiguration implements Serializable {
+  public static final ClientConfiguration EMPTY = ClientConfiguration.builder().build();
 
   /**
    * Optional {@link AwsCredentialsProvider}. If set, this overwrites the default in {@link

diff --git a/...b-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/AsyncPutRecordsHandler.java b/...b-services2/src/main/java/org/apache/beam/sdk/io/aws2/kinesis/AsyncPutRecordsHandler.java