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 <[email protected]> Authored: Wed Jan 6 22:38:20 2016 -0800 Committer: Thomas Weise <[email protected]> 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 ----------------------------------------------------------------------
