beam-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From jbono...@apache.org
Subject [4/4] beam git commit: This closes #3389
Date Tue, 11 Jul 2017 13:48:08 GMT
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é <jbonofre@apache.org>
Authored: Tue Jul 11 15:47:53 2017 +0200
Committer: Jean-Baptiste Onofré <jbonofre@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(-)
----------------------------------------------------------------------



Mime
View raw message