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 858783982a4b039b0ed72109a3c3ff954ce355fd Merge: 6b357c6 da42398 Author: Ismaël Mejía <[email protected]> AuthorDate: Wed Mar 28 19:22:50 2018 +0200 Merge pull request #4851: [BEAM-3819] Add withRequestRecordsLimit() option to KinesisIO .../org/apache/beam/sdk/io/kinesis/KinesisIO.java | 20 ++++++++++++- .../apache/beam/sdk/io/kinesis/KinesisSource.java | 19 +++++++----- .../sdk/io/kinesis/SimplifiedKinesisClient.java | 11 ++++--- .../apache/beam/sdk/io/kinesis/KinesisIOIT.java | 3 +- .../io/kinesis/SimplifiedKinesisClientTest.java | 34 ++++++++++++++++++++++ 5 files changed, 73 insertions(+), 14 deletions(-) -- To stop receiving notification emails like this one, please contact [email protected].
