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:13 UTC

[beam] 01/01: Merge pull request #10078: [BEAM-8542] Change write to async in AWS SNS IO & remove retry logic

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(-)