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 b9c4919 Edit license script for Java, add manual licenses for xz
(#16692)
add 1663d6d [BEAM-13563] Restructure Kinesis Source for Aws 2 internally
to prepare for ClientBuilderFactory
add cc0b2c5 Merge pull request #16657: [BEAM-13563] Restructure Kinesis
Source for AWS 2
No new revisions were added by this update.
Summary of changes:
.../apache/beam/sdk/io/aws2/kinesis/KinesisIO.java | 15 ++--
.../beam/sdk/io/aws2/kinesis/KinesisReader.java | 71 +++++----------
.../beam/sdk/io/aws2/kinesis/KinesisSource.java | 100 ++++-----------------
.../beam/sdk/io/aws2/kinesis/ShardReadersPool.java | 23 ++---
.../sdk/io/aws2/kinesis/KinesisReaderTest.java | 22 +++--
.../sdk/io/aws2/kinesis/ShardReadersPoolTest.java | 73 +++++----------
6 files changed, 89 insertions(+), 215 deletions(-)
