This is an automated email from the ASF dual-hosted git repository.
jkff pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/beam.git
commit 8f7e59c3f24dbfb85b92eb314bcdc622ad1f9ba5
Merge: 2826362 2da05a7
Author: Eugene Kirpichov <ekirpic...@gmail.com>
AuthorDate: Tue Feb 6 11:01:52 2018 -0800
Merge pull request #4586: [BEAM-3611] Split KafkaIO.java in to smaller files
[BEAM-3611] Split KafkaIO.java in to smaller files
.../beam/sdk/io/kafka/KafkaCheckpointMark.java | 6 +-
.../beam/sdk/io/kafka/KafkaExactlyOnceSink.java | 643 +++++++++
.../java/org/apache/beam/sdk/io/kafka/KafkaIO.java | 1431 +-------------------
.../apache/beam/sdk/io/kafka/KafkaRecordCoder.java | 40 +-
.../beam/sdk/io/kafka/KafkaUnboundedReader.java | 663 +++++++++
.../beam/sdk/io/kafka/KafkaUnboundedSource.java | 165 +++
.../org/apache/beam/sdk/io/kafka/KafkaWriter.java | 132 ++
.../org/apache/beam/sdk/io/kafka/ProducerSpEL.java | 12 +-
.../org/apache/beam/sdk/io/kafka/KafkaIOTest.java | 11 +-
9 files changed, 1639 insertions(+), 1464 deletions(-)
--
To stop receiving notification emails like this one, please contact
j...@apache.org.
