beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From github-...@apache.org
Subject [beam] tag nightly-master updated (d20e063 -> 92386d7)
Date Sat, 05 Jun 2021 03:10:51 GMT
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

Mime
View raw message