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 2021/10/27 11:10:33 UTC
[beam] branch master updated (0b9fb71 -> 6220e47)
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 0b9fb71 Merge pull request #15606 from ihji/BEAM-12978
add c4f0434 [BEAM-8958] Use AWS credentials provider with BasicKinesisProvider (AWS sdk v2) rather than supporting basic credentials only.
add 6220e47 Merge pull request #15788: [BEAM-8958] Use AWS credentials provider with BasicKinesisProvider (AWS sdk v2)
No new revisions were added by this update.
Summary of changes:
.../sdk/io/aws2/kinesis/BasicKinesisProvider.java | 41 +++++++---
.../apache/beam/sdk/io/aws2/kinesis/KinesisIO.java | 48 +++++++++--
.../BasicKinesisClientProviderTest.java} | 21 ++---
.../sdk/io/aws2/kinesis/KinesisIOReadTest.java | 92 ++++++++++++++++++++++
4 files changed, 177 insertions(+), 25 deletions(-)
copy sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/{dynamodb/BasicDynamoDbClientProviderTest.java => kinesis/BasicKinesisClientProviderTest.java} (74%)
create mode 100644 sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/kinesis/KinesisIOReadTest.java