You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by hs...@apache.org on 2015/11/17 21:47:32 UTC
[1/2] incubator-apex-malhar git commit: MLHR-1885: Adding getters to
the variables of KafkaMessage nested class
Repository: incubator-apex-malhar
Updated Branches:
refs/heads/devel-3 1bfd2d15a -> 658118a6f
MLHR-1885: Adding getters to the variables of KafkaMessage nested class
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/68574cb4
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/68574cb4
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/68574cb4
Branch: refs/heads/devel-3
Commit: 68574cb4a84981121956df1e96ef913b1d2b658d
Parents: 83f297e
Author: Chaitanya <ch...@datatorrent.com>
Authored: Thu Oct 29 13:58:29 2015 +0530
Committer: Chaitanya <ch...@datatorrent.com>
Committed: Mon Nov 2 14:08:29 2015 +0530
----------------------------------------------------------------------
.../contrib/kafka/KafkaConsumer.java | 20 +++++++++++++++++---
1 file changed, 17 insertions(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/68574cb4/contrib/src/main/java/com/datatorrent/contrib/kafka/KafkaConsumer.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/kafka/KafkaConsumer.java b/contrib/src/main/java/com/datatorrent/contrib/kafka/KafkaConsumer.java
index d6e06c4..cf5179c 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/kafka/KafkaConsumer.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/kafka/KafkaConsumer.java
@@ -32,8 +32,6 @@ import java.util.concurrent.Executors;
import java.util.concurrent.ScheduledExecutorService;
import java.util.concurrent.TimeUnit;
-import kafka.message.Message;
-
import javax.validation.constraints.NotNull;
import javax.validation.constraints.Pattern;
import javax.validation.constraints.Pattern.Flag;
@@ -41,13 +39,16 @@ import javax.validation.constraints.Pattern.Flag;
import org.apache.commons.io.IOUtils;
import org.apache.commons.lang3.StringUtils;
-import com.datatorrent.api.Context;
import com.esotericsoftware.kryo.serializers.FieldSerializer.Bind;
import com.esotericsoftware.kryo.serializers.JavaSerializer;
import com.google.common.collect.HashMultimap;
import com.google.common.collect.Maps;
import com.google.common.collect.SetMultimap;
+import com.datatorrent.api.Context;
+
+import kafka.message.Message;
+
/**
* Base Kafka Consumer class used by kafka input operator
*
@@ -342,7 +343,20 @@ public abstract class KafkaConsumer implements Closeable
this.msg = msg;
this.offSet = offset;
}
+ public KafkaPartition getKafkaPart()
+ {
+ return kafkaPart;
+ }
+ public Message getMsg()
+ {
+ return msg;
+ }
+
+ public long getOffSet()
+ {
+ return offSet;
+ }
}
public static class KafkaMeterStatsUtil {
[2/2] incubator-apex-malhar git commit: Merge branch
'MLHR-1885-AddGetters-devel3' of
https://github.com/chaithu14/incubator-apex-malhar into devel-3
Posted by hs...@apache.org.
Merge branch 'MLHR-1885-AddGetters-devel3' of https://github.com/chaithu14/incubator-apex-malhar into devel-3
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/658118a6
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/658118a6
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/658118a6
Branch: refs/heads/devel-3
Commit: 658118a6ffeb96551cbec75db0107b2431a4eb03
Parents: 1bfd2d1 68574cb
Author: Siyuan Hua <hs...@apache.org>
Authored: Tue Nov 17 12:46:50 2015 -0800
Committer: Siyuan Hua <hs...@apache.org>
Committed: Tue Nov 17 12:46:50 2015 -0800
----------------------------------------------------------------------
.../contrib/kafka/KafkaConsumer.java | 20 +++++++++++++++++---
1 file changed, 17 insertions(+), 3 deletions(-)
----------------------------------------------------------------------