This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git.
from a0ec59b Merge pull request #9059: [BEAM-7743] Fix stream position bug
in BigQuery Storage stream source.
add 885bd50 [BEAM-7557] - Migrate DynamoDBIO to AWS SDK for Java 2
add ccfd31e Merge pull request #9086: [BEAM-7557] Migrate DynamoDBIO to
AWS SDK for Java 2
No new revisions were added by this update.
Summary of changes:
.../org/apache/beam/gradle/BeamModulePlugin.groovy | 2 +
.../beam/sdk/io/aws/dynamodb/DynamoDBIO.java | 22 +-
sdks/java/io/amazon-web-services2/build.gradle | 3 +
.../sdk/io/aws2}/dynamodb/AttributeValueCoder.java | 116 ++++----
.../aws2/dynamodb/BasicDynamoDbClientProvider.java | 57 ++++
.../beam/sdk/io/aws2}/dynamodb/DynamoDBIO.java | 228 ++++++++-------
.../io/aws2/dynamodb/DynamoDbClientProvider.java} | 13 +-
.../beam/sdk/io/aws2}/dynamodb/package-info.java | 2 +-
.../io/aws2}/dynamodb/AttributeValueCoderTest.java | 59 ++--
.../beam/sdk/io/aws2/dynamodb/DynamoDBIOTest.java | 311 +++++++++++++++++++++
.../sdk/io/aws2/dynamodb/DynamoDBIOTestHelper.java | 216 ++++++++++++++
.../aws2/dynamodb/DynamoDbClientProviderMock.java | 27 +-
12 files changed, 815 insertions(+), 241 deletions(-)
copy
sdks/java/io/{amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws =>
amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2}/dynamodb/AttributeValueCoder.java
(54%)
create mode 100644
sdks/java/io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/BasicDynamoDbClientProvider.java
copy
sdks/java/io/{amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws =>
amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2}/dynamodb/DynamoDBIO.java
(72%)
copy
sdks/java/{core/src/main/java/org/apache/beam/sdk/transforms/SerializableComparator.java
=>
io/amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2/dynamodb/DynamoDbClientProvider.java}
(67%)
copy
sdks/java/io/{amazon-web-services/src/main/java/org/apache/beam/sdk/io/aws =>
amazon-web-services2/src/main/java/org/apache/beam/sdk/io/aws2}/dynamodb/package-info.java
(94%)
copy
sdks/java/io/{amazon-web-services/src/test/java/org/apache/beam/sdk/io/aws =>
amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2}/dynamodb/AttributeValueCoderTest.java
(76%)
create mode 100644
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/dynamodb/DynamoDBIOTest.java
create mode 100644
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/dynamodb/DynamoDBIOTestHelper.java
copy
runners/jet-experimental/src/main/java/org/apache/beam/runners/jet/metrics/GaugeImpl.java
=>
sdks/java/io/amazon-web-services2/src/test/java/org/apache/beam/sdk/io/aws2/dynamodb/DynamoDbClientProviderMock.java
(59%)
