apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [37/50] [abbrv] incubator-apex-malhar git commit: Merge branch 'MLHR-1904' of https://github.com/siyuanh/incubator-apex-malhar into kafka09
Date Fri, 29 Jan 2016 19:12:54 GMT
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 <thomas@datatorrent.com>
Authored: Wed Jan 6 22:38:20 2016 -0800
Committer: Thomas Weise <thomas@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
----------------------------------------------------------------------


Mime
View raw message