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

…che#21429)
mosche · Jul 11, 2023 · 59c247f · 59c247f
1 parent a0004b3
commit 59c247f
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