You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ar...@apache.org on 2020/05/05 10:49:12 UTC
[beam] branch master updated (2f3cb62 -> 7c7bcd7)
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 2f3cb62 Merge pull request #11527: Update error prone plugin
add 2495a04 Changed sns writes to async
add bd85e10 [BEAM-8542] V2 async changes for SNSIO
new 7c7bcd7 Merge pull request #10078: [BEAM-8542] Change write to async in AWS SNS IO & remove retry logic
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
...Comparator.java => SerializableBiConsumer.java} | 10 +-
.../BasicSnsAsyncClientProvider.java} | 18 +-
.../SnsAsyncClientProvider.java} | 12 +-
.../beam/sdk/io/aws2/sns/SnsClientProvider.java | 2 +-
.../org/apache/beam/sdk/io/aws2/sns/SnsIO.java | 188 ++++++++++++++++++++-
.../apache/beam/sdk/io/aws2/sns/SnsResponse.java | 55 ++++++
.../beam/sdk/io/aws2/sns/SnsResponseCoder.java | 95 +++++++++++
.../sdk/io/aws2/sns/MockSnsAsyncBaseClient.java} | 16 +-
.../beam/sdk/io/aws2/sns/MockSnsAsyncClient.java} | 36 ++--
.../io/aws2/sns/MockSnsAsyncExceptionClient.java} | 28 +--
.../beam/sdk/io/aws2/sns/SnsIOWriteTest.java | 165 ++++++++++++++++++
.../beam/sdk/io/aws2/sns/SnsResponseCoderTest.java | 77 +++++++++
12 files changed, 643 insertions(+), 59 deletions(-)
copy sdks/java/core/src/main/java/org/apache/beam/sdk/transforms/{SerializableComparator.java => SerializableBiConsumer.java} (72%)
copy sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/{dynamodb/BasicDynamoDbClientProvider.java => sns/BasicSnsAsyncClientProvider.java} (78%)
copy sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/{dynamodb/DynamoDbClientProvider.java => sns/SnsAsyncClientProvider.java} (74%)
create mode 100644 sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/SnsResponse.java
create mode 100644 sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/sns/SnsResponseCoder.java
copy sdks/java/io/amazon-web-services2/src/{main/java/org/apache/beam/sdk/io/aws2/sns/package-info.java => test/java/org/apache/beam/sdk/io/aws2/sns/MockSnsAsyncBaseClient.java} (76%)
copy sdks/java/io/amazon-web-services2/src/{main/java/org/apache/beam/sdk/io/aws2/sns/PublishResponseCoder.java => test/java/org/apache/beam/sdk/io/aws2/sns/MockSnsAsyncClient.java} (50%)
copy sdks/java/io/amazon-web-services2/src/{main/java/org/apache/beam/sdk/io/aws2/sns/SnsCoderProviderRegistrar.java => test/java/org/apache/beam/sdk/io/aws2/sns/MockSnsAsyncExceptionClient.java} (55%)
create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sns/SnsIOWriteTest.java
create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sns/SnsResponseCoderTest.java
[beam] 01/01: Merge pull request #10078: [BEAM-8542] Change write
to async in AWS SNS IO & remove retry logic
Posted by ar...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
aromanenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 7c7bcd71db1999e306035b0aa9ccbd591bca3e9f
Merge: 2f3cb62 bd85e10
Author: Alexey Romanenko <33...@users.noreply.github.com>
AuthorDate: Tue May 5 12:48:52 2020 +0200
Merge pull request #10078: [BEAM-8542] Change write to async in AWS SNS IO & remove retry logic
.../sdk/transforms/SerializableBiConsumer.java} | 15 +-
.../io/aws2/sns/BasicSnsAsyncClientProvider.java | 57 +++++++
...ntProvider.java => SnsAsyncClientProvider.java} | 12 +-
.../beam/sdk/io/aws2/sns/SnsClientProvider.java | 2 +-
.../org/apache/beam/sdk/io/aws2/sns/SnsIO.java | 188 ++++++++++++++++++++-
.../apache/beam/sdk/io/aws2/sns/SnsResponse.java | 55 ++++++
.../beam/sdk/io/aws2/sns/SnsResponseCoder.java | 95 +++++++++++
.../sdk/io/aws2/sns/MockSnsAsyncBaseClient.java} | 18 +-
.../beam/sdk/io/aws2/sns/MockSnsAsyncClient.java | 46 +++++
.../io/aws2/sns/MockSnsAsyncExceptionClient.java} | 27 +--
.../beam/sdk/io/aws2/sns/SnsIOWriteTest.java | 165 ++++++++++++++++++
.../beam/sdk/io/aws2/sns/SnsResponseCoderTest.java | 77 +++++++++
12 files changed, 721 insertions(+), 36 deletions(-)