apex-commits mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From t..@apache.org
Subject [3/4] incubator-apex-malhar git commit: Merge branch 'APEXMALHAR-1983' of https://github.com/siyuanh/incubator-apex-malhar into APEXMALHAR-1983
Date Sat, 30 Jan 2016 19:32:18 GMT
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 <v.rozov@datatorrent.com>
Authored: Fri Jan 29 21:51:18 2016 -0800
Committer: Vlad Rozov <v.rozov@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
----------------------------------------------------------------------


Mime
View raw message