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 6b4b8fa07e4e88f45ec1d4a4c692cc3f6fb545ac Merge: 30dbf5c 2baeeb9 Author: Ismaël Mejía <[email protected]> AuthorDate: Wed Feb 7 15:02:27 2018 +0100 Merge pull request #4468: [BEAM-3291] Add Kinesis write transform sdks/java/io/kinesis/build.gradle | 1 + sdks/java/io/kinesis/pom.xml | 34 +- .../beam/sdk/io/kinesis/AWSClientsProvider.java | 9 +- .../beam/sdk/io/kinesis/BasicKinesisProvider.java | 90 +++++ .../org/apache/beam/sdk/io/kinesis/KinesisIO.java | 446 ++++++++++++++++++--- ...lientsProvider.java => KinesisPartitioner.java} | 16 +- .../beam/sdk/io/kinesis/AmazonKinesisMock.java | 11 + .../apache/beam/sdk/io/kinesis/KinesisIOIT.java | 126 ++++++ .../beam/sdk/io/kinesis/KinesisMockReadTest.java | 2 +- .../beam/sdk/io/kinesis/KinesisMockWriteTest.java | 289 +++++++++++++ .../beam/sdk/io/kinesis/KinesisProducerMock.java | 120 ++++++ .../beam/sdk/io/kinesis/KinesisReaderIT.java | 121 ------ .../beam/sdk/io/kinesis/KinesisServiceMock.java | 88 ++++ 13 files changed, 1159 insertions(+), 194 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
