You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by vr...@apache.org on 2016/01/30 07:02:14 UTC

[2/2] incubator-apex-malhar git commit: Merge branch 'APEXMALHAR-1983' of https://github.com/siyuanh/incubator-apex-malhar into APEXMALHAR-1983

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/devel-3
Commit: a44e81a835f7a498838f4b3e44a0b81726eb03d1
Parents: ab80023 0627199
Author: Vlad Rozov <v....@datatorrent.com>
Authored: Fri Jan 29 21:51:18 2016 -0800
Committer: Vlad Rozov <v....@datatorrent.com>
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
----------------------------------------------------------------------