You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jk...@apache.org on 2017/10/31 23:03:13 UTC
[2/2] beam git commit: This closes #3930: [BEAM-2468] Reading Kinesis
records in the background
This closes #3930: [BEAM-2468] Reading Kinesis records in the background
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/612af0a2
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/612af0a2
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/612af0a2
Branch: refs/heads/master
Commit: 612af0a296550e6ae12033aa75ed5ffac7650382
Parents: c53a121 ec39446
Author: Eugene Kirpichov <ki...@google.com>
Authored: Tue Oct 31 16:02:57 2017 -0700
Committer: Eugene Kirpichov <ki...@google.com>
Committed: Tue Oct 31 16:02:57 2017 -0700
----------------------------------------------------------------------
.../beam/sdk/io/kinesis/KinesisReader.java | 43 ++---
.../sdk/io/kinesis/KinesisReaderCheckpoint.java | 18 --
.../apache/beam/sdk/io/kinesis/RoundRobin.java | 54 ------
.../beam/sdk/io/kinesis/ShardCheckpoint.java | 8 +-
.../beam/sdk/io/kinesis/ShardReadersPool.java | 162 ++++++++++++++++
.../sdk/io/kinesis/ShardRecordsIterator.java | 90 ++++-----
.../beam/sdk/io/kinesis/KinesisReaderTest.java | 66 +++----
.../beam/sdk/io/kinesis/RoundRobinTest.java | 59 ------
.../sdk/io/kinesis/ShardReadersPoolTest.java | 185 +++++++++++++++++++
.../io/kinesis/ShardRecordsIteratorTest.java | 35 ++--
10 files changed, 454 insertions(+), 266 deletions(-)
----------------------------------------------------------------------