Merge branch 'APEXMALHAR-1983' of https://github.com/siyuanh/incubator-apex-malhar into APEXMALHAR-1983
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/a44e81a8 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/a44e81a8 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/a44e81a8 Branch: refs/heads/master Commit: a44e81a835f7a498838f4b3e44a0b81726eb03d1 Parents: ab80023 0627199 Author: Vlad Rozov <[email protected]> Authored: Fri Jan 29 21:51:18 2016 -0800 Committer: Vlad Rozov <[email protected]> Committed: Fri Jan 29 21:51:18 2016 -0800 ---------------------------------------------------------------------- .../malhar/kafka/AbstractKafkaInputOperator.java | 15 ++++++++++----- .../apex/malhar/kafka/AbstractKafkaPartitioner.java | 4 +++- .../apex/malhar/kafka/KafkaConsumerWrapper.java | 2 ++ .../org/apache/apex/malhar/kafka/KafkaMetrics.java | 2 ++ .../org/apache/apex/malhar/kafka/KafkaPartition.java | 3 +++ .../apex/malhar/kafka/OneToManyPartitioner.java | 2 ++ .../apex/malhar/kafka/OneToOnePartitioner.java | 2 ++ .../apache/apex/malhar/kafka/PartitionStrategy.java | 3 +++ 8 files changed, 27 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/a44e81a8/kafka/src/main/java/org/apache/apex/malhar/kafka/AbstractKafkaPartitioner.java ----------------------------------------------------------------------
