You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by ie...@apache.org on 2018/01/30 13:50:11 UTC
[beam] 01/01: Merge pull request #4243: [BEAM-2469] Handling
Kinesis shards splits and merges
This is an automated email from the ASF dual-hosted git repository.
iemejia pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 5391053039f2e9951f05d50898530f3b81d54252
Merge: dc24beb 994c7f3
Author: Ismaël Mejía <ie...@gmail.com>
AuthorDate: Tue Jan 30 14:50:02 2018 +0100
Merge pull request #4243: [BEAM-2469] Handling Kinesis shards splits and merges
.../sdk/io/kinesis/DynamicCheckpointGenerator.java | 27 ++-
.../apache/beam/sdk/io/kinesis/KinesisReader.java | 12 +-
.../io/kinesis/KinesisShardClosedException.java | 28 +++
.../beam/sdk/io/kinesis/ShardReadersPool.java | 167 +++++++++++--
.../beam/sdk/io/kinesis/ShardRecordsIterator.java | 27 ++-
.../sdk/io/kinesis/StartingPointShardsFinder.java | 193 +++++++++++++++
.../io/kinesis/DynamicCheckpointGeneratorTest.java | 35 ++-
.../beam/sdk/io/kinesis/KinesisReaderTest.java | 20 +-
.../beam/sdk/io/kinesis/ShardReadersPoolTest.java | 126 ++++++++--
.../sdk/io/kinesis/ShardRecordsIteratorTest.java | 6 +-
.../io/kinesis/StartingPointShardsFinderTest.java | 264 +++++++++++++++++++++
11 files changed, 856 insertions(+), 49 deletions(-)
--
To stop receiving notification emails like this one, please contact
iemejia@apache.org.