Add config translations for getComponentConfiguration() (#2592)
diff --git a/storm-compatibility/src/java/backtype/storm/topology/IRichBoltDelegate.java b/storm-compatibility/src/java/backtype/storm/topology/IRichBoltDelegate.java
index 9289aa8..ee79c6f 100644
--- a/storm-compatibility/src/java/backtype/storm/topology/IRichBoltDelegate.java
+++ b/storm-compatibility/src/java/backtype/storm/topology/IRichBoltDelegate.java
@@ -26,6 +26,7 @@
import backtype.storm.task.OutputCollectorImpl;
import backtype.storm.task.TopologyContext;
import backtype.storm.tuple.TupleImpl;
+import backtype.storm.utils.ConfigUtils;
/**
* When writing topologies using Java, {@link IRichBolt} and {@link IRichSpout} are the main interfaces
@@ -73,7 +74,8 @@
@Override
public Map<String, Object> getComponentConfiguration() {
- return delegate.getComponentConfiguration();
+ Map<String, Object> config = delegate.getComponentConfiguration();
+ return ConfigUtils.translateComponentConfig(config);
}
@Override
diff --git a/storm-compatibility/src/java/backtype/storm/topology/IRichSpoutDelegate.java b/storm-compatibility/src/java/backtype/storm/topology/IRichSpoutDelegate.java
index 7ec12cd..1f02861 100644
--- a/storm-compatibility/src/java/backtype/storm/topology/IRichSpoutDelegate.java
+++ b/storm-compatibility/src/java/backtype/storm/topology/IRichSpoutDelegate.java
@@ -26,6 +26,7 @@
import backtype.storm.spout.SpoutOutputCollectorImpl;
import backtype.storm.task.TopologyContext;
+import backtype.storm.utils.ConfigUtils;
/**
* When writing topologies using Java, {@link IRichBolt} and {@link IRichSpout} are the main interfaces
@@ -90,7 +91,8 @@
@Override
public Map<String, Object> getComponentConfiguration() {
- return delegate.getComponentConfiguration();
+ Map<String, Object> config = delegate.getComponentConfiguration();
+ return ConfigUtils.translateComponentConfig(config);
}
@Override
diff --git a/storm-compatibility/src/java/org/apache/storm/topology/IRichBoltDelegate.java b/storm-compatibility/src/java/org/apache/storm/topology/IRichBoltDelegate.java
index dfddfa8..8a7ca44 100644
--- a/storm-compatibility/src/java/org/apache/storm/topology/IRichBoltDelegate.java
+++ b/storm-compatibility/src/java/org/apache/storm/topology/IRichBoltDelegate.java
@@ -24,6 +24,7 @@
import org.apache.storm.task.OutputCollectorImpl;
import org.apache.storm.task.TopologyContext;
import org.apache.storm.tuple.TupleImpl;
+import org.apache.storm.utils.ConfigUtils;
import com.twitter.heron.api.topology.IUpdatable;
@@ -73,7 +74,8 @@
@Override
public Map<String, Object> getComponentConfiguration() {
- return delegate.getComponentConfiguration();
+ Map<String, Object> config = delegate.getComponentConfiguration();
+ return ConfigUtils.translateComponentConfig(config);
}
@Override
diff --git a/storm-compatibility/src/java/org/apache/storm/topology/IRichSpoutDelegate.java b/storm-compatibility/src/java/org/apache/storm/topology/IRichSpoutDelegate.java
index 6232e8a..df7e698 100644
--- a/storm-compatibility/src/java/org/apache/storm/topology/IRichSpoutDelegate.java
+++ b/storm-compatibility/src/java/org/apache/storm/topology/IRichSpoutDelegate.java
@@ -23,6 +23,7 @@
import org.apache.storm.spout.SpoutOutputCollectorImpl;
import org.apache.storm.task.TopologyContext;
+import org.apache.storm.utils.ConfigUtils;
import com.twitter.heron.api.spout.SpoutOutputCollector;
import com.twitter.heron.api.topology.IUpdatable;
@@ -90,7 +91,8 @@
@Override
public Map<String, Object> getComponentConfiguration() {
- return delegate.getComponentConfiguration();
+ Map<String, Object> config = delegate.getComponentConfiguration();
+ return ConfigUtils.translateComponentConfig(config);
}
@Override
diff --git a/storm-compatibility/src/java/org/apache/storm/topology/IWindowedBoltDelegate.java b/storm-compatibility/src/java/org/apache/storm/topology/IWindowedBoltDelegate.java
index 46be02a..7ac1f25 100644
--- a/storm-compatibility/src/java/org/apache/storm/topology/IWindowedBoltDelegate.java
+++ b/storm-compatibility/src/java/org/apache/storm/topology/IWindowedBoltDelegate.java
@@ -22,6 +22,7 @@
import org.apache.storm.task.OutputCollectorImpl;
import org.apache.storm.task.TopologyContext;
import org.apache.storm.tuple.TupleImpl;
+import org.apache.storm.utils.ConfigUtils;
import org.apache.storm.windowing.TupleWindowImpl;
public class IWindowedBoltDelegate implements com.twitter.heron.api.bolt.IWindowedBolt {
@@ -43,7 +44,8 @@
@Override
public Map<String, Object> getComponentConfiguration() {
- return this.delegate.getComponentConfiguration();
+ Map<String, Object> config = delegate.getComponentConfiguration();
+ return ConfigUtils.translateComponentConfig(config);
}
@Override
