This is an automated email from the ASF dual-hosted git repository.
github-bot pushed a change to tag nightly-master
in repository https://gitbox.apache.org/repos/asf/beam.git.
*** WARNING: tag nightly-master was modified! ***
from d20e063 (commit)
to 92386d7 (commit)
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
add ba5e212 Merge pull request #14743: [BEAM-12225] Replace AWS API used
to list shards from DescribeStream to ListShards
add a4abc91 [BEAM-12434] Implement side_input for num_shards in iobase
(#14916)
add 92386d7 [BEAM-12410] SamzaPortablePipelineOptions to extend
PortablePipelineOptions (#14944)
No new revisions were added by this update.
Summary of changes:
CHANGES.md | 2 +-
.../apache/beam/runners/samza/SamzaJobInvoker.java | 4 +-
.../samza/SamzaPortablePipelineOptions.java | 23 +-
.../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 ---------------------
sdks/python/apache_beam/io/iobase.py | 16 +-
18 files changed, 511 insertions(+), 703 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
