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
----------------------------------------------------------------------