Closes #687
Project: http://git-wip-us.apache.org/repos/asf/incubator-beam/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-beam/commit/a17a99f5 Tree: http://git-wip-us.apache.org/repos/asf/incubator-beam/tree/a17a99f5 Diff: http://git-wip-us.apache.org/repos/asf/incubator-beam/diff/a17a99f5 Branch: refs/heads/master Commit: a17a99f580d9818e11751b6996a15aa60b2e0c56 Parents: 95ab438 a5005fb Author: Dan Halperin <dhalp...@google.com> Authored: Fri Aug 26 16:12:08 2016 -0700 Committer: Dan Halperin <dhalp...@google.com> Committed: Fri Aug 26 16:12:08 2016 -0700 ---------------------------------------------------------------------- sdks/java/io/kinesis/pom.xml | 179 +++++++++ .../sdk/io/kinesis/CheckpointGenerator.java | 30 ++ .../beam/sdk/io/kinesis/CustomOptional.java | 85 +++++ .../io/kinesis/DynamicCheckpointGenerator.java | 56 +++ .../sdk/io/kinesis/GetKinesisRecordsResult.java | 54 +++ .../sdk/io/kinesis/KinesisClientProvider.java | 31 ++ .../apache/beam/sdk/io/kinesis/KinesisIO.java | 190 ++++++++++ .../beam/sdk/io/kinesis/KinesisReader.java | 145 +++++++ .../sdk/io/kinesis/KinesisReaderCheckpoint.java | 96 +++++ .../beam/sdk/io/kinesis/KinesisRecord.java | 121 ++++++ .../beam/sdk/io/kinesis/KinesisRecordCoder.java | 74 ++++ .../beam/sdk/io/kinesis/KinesisSource.java | 112 ++++++ .../beam/sdk/io/kinesis/RecordFilter.java | 41 ++ .../apache/beam/sdk/io/kinesis/RoundRobin.java | 53 +++ .../beam/sdk/io/kinesis/ShardCheckpoint.java | 175 +++++++++ .../sdk/io/kinesis/ShardRecordsIterator.java | 98 +++++ .../sdk/io/kinesis/SimplifiedKinesisClient.java | 157 ++++++++ .../beam/sdk/io/kinesis/StartingPoint.java | 85 +++++ .../io/kinesis/StaticCheckpointGenerator.java | 42 +++ .../io/kinesis/TransientKinesisException.java | 29 ++ .../beam/sdk/io/kinesis/package-info.java | 22 ++ .../beam/sdk/io/kinesis/AmazonKinesisMock.java | 375 +++++++++++++++++++ .../beam/sdk/io/kinesis/CustomOptionalTest.java | 31 ++ .../kinesis/DynamicCheckpointGeneratorTest.java | 57 +++ .../sdk/io/kinesis/KinesisMockReadTest.java | 91 +++++ .../io/kinesis/KinesisReaderCheckpointTest.java | 67 ++++ .../beam/sdk/io/kinesis/KinesisReaderIT.java | 119 ++++++ .../beam/sdk/io/kinesis/KinesisReaderTest.java | 120 ++++++ .../sdk/io/kinesis/KinesisRecordCoderTest.java | 45 +++ .../beam/sdk/io/kinesis/KinesisTestOptions.java | 47 +++ .../beam/sdk/io/kinesis/KinesisUploader.java | 84 +++++ .../beam/sdk/io/kinesis/RecordFilterTest.java | 66 ++++ .../beam/sdk/io/kinesis/RoundRobinTest.java | 57 +++ .../sdk/io/kinesis/ShardCheckpointTest.java | 149 ++++++++ .../io/kinesis/ShardRecordsIteratorTest.java | 151 ++++++++ .../io/kinesis/SimplifiedKinesisClientTest.java | 224 +++++++++++ .../beam/sdk/io/kinesis/package-info.java | 22 ++ sdks/java/io/pom.xml | 1 + 38 files changed, 3581 insertions(+) ----------------------------------------------------------------------