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-...@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(-)
