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
