You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@beam.apache.org by jb...@apache.org on 2017/07/11 13:48:08 UTC
[4/4] beam git commit: This closes #3389
This closes #3389
Project: http://git-wip-us.apache.org/repos/asf/beam/repo
Commit: http://git-wip-us.apache.org/repos/asf/beam/commit/138641f1
Tree: http://git-wip-us.apache.org/repos/asf/beam/tree/138641f1
Diff: http://git-wip-us.apache.org/repos/asf/beam/diff/138641f1
Branch: refs/heads/master
Commit: 138641f140b037841f9a1d2cc8e523ad29dc9518
Parents: af08f53 21fd302
Author: Jean-Baptiste Onofré <jb...@apache.org>
Authored: Tue Jul 11 15:47:53 2017 +0200
Committer: Jean-Baptiste Onofré <jb...@apache.org>
Committed: Tue Jul 11 15:47:53 2017 +0200
----------------------------------------------------------------------
.../sdk/io/kinesis/CheckpointGenerator.java | 6 +-
.../beam/sdk/io/kinesis/CustomOptional.java | 111 ++--
.../io/kinesis/DynamicCheckpointGenerator.java | 52 +-
.../sdk/io/kinesis/GetKinesisRecordsResult.java | 49 +-
.../sdk/io/kinesis/KinesisClientProvider.java | 4 +-
.../apache/beam/sdk/io/kinesis/KinesisIO.java | 279 +++++-----
.../beam/sdk/io/kinesis/KinesisReader.java | 206 +++----
.../sdk/io/kinesis/KinesisReaderCheckpoint.java | 97 ++--
.../beam/sdk/io/kinesis/KinesisRecord.java | 177 +++---
.../beam/sdk/io/kinesis/KinesisRecordCoder.java | 68 +--
.../beam/sdk/io/kinesis/KinesisSource.java | 147 ++---
.../beam/sdk/io/kinesis/RecordFilter.java | 18 +-
.../apache/beam/sdk/io/kinesis/RoundRobin.java | 37 +-
.../beam/sdk/io/kinesis/ShardCheckpoint.java | 241 ++++-----
.../sdk/io/kinesis/ShardRecordsIterator.java | 106 ++--
.../sdk/io/kinesis/SimplifiedKinesisClient.java | 215 ++++----
.../beam/sdk/io/kinesis/StartingPoint.java | 84 +--
.../io/kinesis/StaticCheckpointGenerator.java | 27 +-
.../io/kinesis/TransientKinesisException.java | 7 +-
.../beam/sdk/io/kinesis/AmazonKinesisMock.java | 539 ++++++++++---------
.../beam/sdk/io/kinesis/CustomOptionalTest.java | 27 +-
.../kinesis/DynamicCheckpointGeneratorTest.java | 33 +-
.../sdk/io/kinesis/KinesisMockReadTest.java | 97 ++--
.../io/kinesis/KinesisReaderCheckpointTest.java | 52 +-
.../beam/sdk/io/kinesis/KinesisReaderIT.java | 127 ++---
.../beam/sdk/io/kinesis/KinesisReaderTest.java | 166 +++---
.../sdk/io/kinesis/KinesisRecordCoderTest.java | 34 +-
.../beam/sdk/io/kinesis/KinesisTestOptions.java | 43 +-
.../beam/sdk/io/kinesis/KinesisUploader.java | 70 +--
.../beam/sdk/io/kinesis/RecordFilterTest.java | 52 +-
.../beam/sdk/io/kinesis/RoundRobinTest.java | 42 +-
.../sdk/io/kinesis/ShardCheckpointTest.java | 203 +++----
.../io/kinesis/ShardRecordsIteratorTest.java | 216 ++++----
.../io/kinesis/SimplifiedKinesisClientTest.java | 351 ++++++------
34 files changed, 2031 insertions(+), 1952 deletions(-)
----------------------------------------------------------------------