You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by th...@apache.org on 2016/01/29 20:12:35 UTC
[18/50] [abbrv] incubator-apex-malhar git commit: MLHR-1959 #comment
Added getter for offset manager so that its properties can be set from
property files
MLHR-1959 #comment Added getter for offset manager so that its properties can be set from property files
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/61217c7f
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/61217c7f
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/61217c7f
Branch: refs/heads/master
Commit: 61217c7f05c4d3f0017a24a42644b27a23be6457
Parents: 3a8aaba
Author: Pramod Immaneni <pr...@datatorrent.com>
Authored: Tue Dec 29 18:30:28 2015 -0800
Committer: Pramod Immaneni <pr...@datatorrent.com>
Committed: Tue Dec 29 18:33:06 2015 -0800
----------------------------------------------------------------------
.../datatorrent/contrib/kafka/AbstractKafkaInputOperator.java | 5 +++++
1 file changed, 5 insertions(+)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/61217c7f/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
----------------------------------------------------------------------
diff --git a/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java b/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
index ec50615..2343ba2 100644
--- a/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
+++ b/contrib/src/main/java/com/datatorrent/contrib/kafka/AbstractKafkaInputOperator.java
@@ -942,6 +942,11 @@ public abstract class AbstractKafkaInputOperator<K extends KafkaConsumer> implem
this.offsetManager = offsetManager;
}
+ public OffsetManager getOffsetManager()
+ {
+ return offsetManager;
+ }
+
public void setRepartitionCheckInterval(long repartitionCheckInterval)
{
this.repartitionCheckInterval = repartitionCheckInterval;