You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/01/29 20:12:54 UTC
[37/50] [abbrv] incubator-apex-malhar git commit: Merge branch
'MLHR-1904' of https://github.com/siyuanh/incubator-apex-malhar into kafka09
Merge branch 'MLHR-1904' of https://github.com/siyuanh/incubator-apex-malhar into kafka09
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/b7199b7d
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/b7199b7d
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/b7199b7d
Branch: refs/heads/master
Commit: b7199b7ddc30e7d05e7294209f9215a7106f2de5
Parents: 91ca27a 7ee2c7e
Author: Thomas Weise <th...@datatorrent.com>
Authored: Wed Jan 6 22:38:20 2016 -0800
Committer: Thomas Weise <th...@datatorrent.com>
Committed: Wed Jan 6 22:38:20 2016 -0800
----------------------------------------------------------------------
kafka/XmlJavadocCommentsExtractor.xsl | 48 ++
kafka/pom.xml | 229 ++++++++
.../kafka/AbstractKafkaInputOperator.java | 527 +++++++++++++++++++
.../malhar/kafka/AbstractKafkaPartitioner.java | 278 ++++++++++
.../apex/malhar/kafka/KafkaConsumerWrapper.java | 328 ++++++++++++
.../apache/apex/malhar/kafka/KafkaMetrics.java | 136 +++++
.../apex/malhar/kafka/KafkaPartition.java | 143 +++++
.../kafka/KafkaSinglePortInputOperator.java | 44 ++
.../apex/malhar/kafka/OneToManyPartitioner.java | 66 +++
.../apex/malhar/kafka/OneToOnePartitioner.java | 56 ++
.../apex/malhar/kafka/PartitionStrategy.java | 38 ++
.../malhar/kafka/KafkaInputOperatorTest.java | 216 ++++++++
.../malhar/kafka/KafkaOperatorTestBase.java | 308 +++++++++++
.../apex/malhar/kafka/KafkaTestPartitioner.java | 62 +++
.../apex/malhar/kafka/KafkaTestProducer.java | 169 ++++++
pom.xml | 1 +
16 files changed, 2649 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/b7199b7d/pom.xml
----------------------------------------------------------------------