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 737be25 [BEAM-13685] Enable users to specify cache directory under
Interactive Beam options
add 976b14c [BEAM-13653] Make SnsIO.write topicArn optional. If provided,
validate it and force usage on the Sns publish request.
add b521b3f Merge pull request #16503: [BEAM-13653] Fix usage of
SnsIO.write topicArn (AWS Sdk v2)
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/sdk/io/aws2/sns/SnsIO.java | 96 ++++++-----
.../apache/beam/sdk/io/aws2/StaticSupplier.java} | 36 ++--
.../dynamodb/StaticDynamoDBClientProvider.java | 32 +---
.../beam/sdk/io/aws2/sns/SnsClientMockErrors.java | 52 ------
.../beam/sdk/io/aws2/sns/SnsClientMockSuccess.java | 58 -------
.../org/apache/beam/sdk/io/aws2/sns/SnsIOTest.java | 189 ++++++++++++++-------
.../sdk/io/aws2/sns/StaticSnsClientProvider.java} | 21 ++-
.../org/apache/beam/sdk/io/aws2/sqs/SqsIOTest.java | 2 +-
.../sdk/io/aws2/sqs/SqsUnboundedReaderTest.java | 4 +-
.../sdk/io/aws2/sqs/SqsUnboundedSourceTest.java | 2 +-
...viderMock.java => StaticSqsClientProvider.java} | 18 +-
11 files changed, 230 insertions(+), 280 deletions(-)
copy
sdks/java/{extensions/euphoria/src/test/java/org/apache/beam/sdk/extensions/euphoria/core/testkit/accumulators/LongHistogram.java
=>
io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/StaticSupplier.java}
(53%)
delete mode 100644
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sns/SnsClientMockErrors.java
delete mode 100644
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sns/SnsClientMockSuccess.java
copy
sdks/java/io/amazon-web-services2/src/{main/java/org/apache/beam/sdk/io/aws2/sns/SnsClientProvider.java
=> test/java/org/apache/beam/sdk/io/aws2/sns/StaticSnsClientProvider.java}
(66%)
rename
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/sqs/{SqsClientProviderMock.java
=> StaticSqsClientProvider.java} (69%)
