beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From aromane...@apache.org
Subject [beam] 01/01: Merge pull request #14743: [BEAM-12225] Replace AWS API used to list shards from DescribeStream to ListShards
Date Fri, 04 Jun 2021 13:43:44 GMT
This is an automated email from the ASF dual-hosted git repository.

aromanenko pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git

commit ba5e2124b3c999e49ac1e4f76a1c02290bbf5278
Merge: d20e063 ca3d55b
Author: Alexey Romanenko <33895511+aromanenko-dev@users.noreply.github.com>
AuthorDate: Fri Jun 4 15:42:55 2021 +0200

    Merge pull request #14743: [BEAM-12225] Replace AWS API used to list shards from DescribeStream
to ListShards

 CHANGES.md                                         |   2 +-
 .../sdk/io/kinesis/DynamicCheckpointGenerator.java |  23 +-
 .../sdk/io/kinesis/KinesisReaderCheckpoint.java    |   5 +
 .../beam/sdk/io/kinesis/ShardReadersPool.java      |  46 +++-
 .../beam/sdk/io/kinesis/ShardRecordsIterator.java  |   6 +-
 .../sdk/io/kinesis/SimplifiedKinesisClient.java    | 164 +++++++++---
 .../apache/beam/sdk/io/kinesis/StartingPoint.java  |   7 +-
 .../sdk/io/kinesis/StartingPointShardsFinder.java  | 205 ---------------
 .../beam/sdk/io/kinesis/AmazonKinesisMock.java     |  74 +++---
 .../io/kinesis/DynamicCheckpointGeneratorTest.java |  35 +--
 .../beam/sdk/io/kinesis/KinesisMockReadTest.java   |  15 +-
 .../beam/sdk/io/kinesis/KinesisMockWriteTest.java  |  25 +-
 .../beam/sdk/io/kinesis/ShardReadersPoolTest.java  |   8 +-
 .../io/kinesis/SimplifiedKinesisClientTest.java    | 275 +++++++++++++++++++-
 .../io/kinesis/StartingPointShardsFinderTest.java  | 281 ---------------------
 15 files changed, 501 insertions(+), 670 deletions(-)

Mime
View raw message