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/29 15:19:35 UTC
[beam] branch master updated (643825b -> 67ef9ac)
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 643825b Merge pull request #15801 from [BEAM-12970][Playground] Implement gRPC API - GetCompileOutput
add 67ef9ac [BEAM-8958] Use AWS credentials provider with BasicKinesisProvider (kinesis v1) (#15816)
No new revisions were added by this update.
Summary of changes:
sdks/java/io/kinesis/build.gradle | 3 +
.../beam/sdk/io/kinesis/BasicKinesisProvider.java | 46 +++--
.../org/apache/beam/sdk/io/kinesis/KinesisIO.java | 140 +++++++++++--
.../beam/sdk/io/kinesis/serde/AwsModule.java | 222 +++++++++++++++++++++
.../io/kinesis/serde}/AwsSerializableUtils.java | 12 +-
.../beam/sdk/io/kinesis/serde}/package-info.java | 4 +-
.../kinesis/BasicKinesisClientProviderTest.java | 19 +-
.../beam/sdk/io/kinesis/KinesisIOReadTest.java | 138 +++++++++++++
.../beam/sdk/io/kinesis/KinesisIOWriteTest.java | 130 ++++++++++++
.../beam/sdk/io/kinesis/serde/AwsModuleTest.java | 174 ++++++++++++++++
.../io/kinesis/serde/AwsSerializableUtilsTest.java | 174 ++++++++++++++++
11 files changed, 1014 insertions(+), 48 deletions(-)
create mode 100644 sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/serde/AwsModule.java
copy sdks/java/io/{amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/options => kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/serde}/AwsSerializableUtils.java (79%)
copy sdks/java/io/{amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws/sqs => kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/serde}/package-info.java (90%)
copy sdks/java/io/{amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2 => kinesis/src/test/java/org/apache/beam/sdk/io}/kinesis/BasicKinesisClientProviderTest.java (72%)
create mode 100644 sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisIOReadTest.java
create mode 100644 sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/KinesisIOWriteTest.java
create mode 100644 sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/serde/AwsModuleTest.java
create mode 100644 sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/serde/AwsSerializableUtilsTest.java