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 d20e063 Minor: Add link to DataFrame API reference in "Languages" nav
(#14937)
add ca3d55b [BEAM-12225] List shards using ListShards API instead of
DescribeStream API
new ba5e212 Merge pull request #14743: [BEAM-12225] Replace AWS API used
to list shards from DescribeStream to ListShards
The 1 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
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(-)
delete mode 100644
sdks/java/io/kinesis/src/main/java/org/apache/beam/sdk/io/kinesis/StartingPointShardsFinder.java
delete mode 100644
sdks/java/io/kinesis/src/test/java/org/apache/beam/sdk/io/kinesis/StartingPointShardsFinderTest.java
