You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ar...@apache.org on 2019/11/06 16:09:38 UTC
[beam] branch master updated (9ad416e -> fae96ed)
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 9ad416e Merge pull request #10006: [BEAM-8565] Update .test-infra/jenkins/README to reflect the current state
add 432cfd2 [BEAM-8352] Add "withMaxCapacityPerShard()" to KinesisIO.Read
add fae96ed Merge pull request #9745: [BEAM-8352] Add "withMaxCapacityPerShard()" to KinesisIO.Read
No new revisions were added by this update.
Summary of changes:
.../java/org/apache/beam/sdk/io/kinesis/KinesisIO.java | 14 +++++++++++++-
.../org/apache/beam/sdk/io/kinesis/KinesisReader.java | 16 ++++++++++++----
.../org/apache/beam/sdk/io/kinesis/KinesisSource.java | 17 ++++++++++++-----
.../apache/beam/sdk/io/kinesis/ShardReadersPool.java | 15 +++++++--------
.../apache/beam/sdk/io/kinesis/KinesisReaderTest.java | 3 ++-
.../beam/sdk/io/kinesis/ShardReadersPoolTest.java | 10 ++++++++--
6 files changed, 54 insertions(+), 21 deletions(-)