update storm 2.2.0 ISpout open() (#3567)
* updateispout
* fix-style
* minchange
* updateibolt
Co-authored-by: Huijun Wu <huijunw@twitter.com>
diff --git a/storm-compatibility/v2.2.0/src/java/org/apache/storm/spout/ISpout.java b/storm-compatibility/v2.2.0/src/java/org/apache/storm/spout/ISpout.java
index aee0d0a..bd28845 100644
--- a/storm-compatibility/v2.2.0/src/java/org/apache/storm/spout/ISpout.java
+++ b/storm-compatibility/v2.2.0/src/java/org/apache/storm/spout/ISpout.java
@@ -57,8 +57,7 @@
* @param context This object can be used to get information about this task's place within the topology, including the task id and component id of this task, input and output information, etc.
* @param collector The collector is used to emit tuples from this spout. Tuples can be emitted at any time, including the open and close methods. The collector is thread-safe and should be saved as an instance variable of this spout object.
*/
- @SuppressWarnings("rawtypes")
- void open(Map conf, TopologyContext context, SpoutOutputCollector collector);
+ void open(Map<String, Object> conf, TopologyContext context, SpoutOutputCollector collector);
/**
* Called when an ISpout is going to be shutdown. There is no guarentee that close
diff --git a/storm-compatibility/v2.2.0/src/java/org/apache/storm/topology/IBasicBolt.java b/storm-compatibility/v2.2.0/src/java/org/apache/storm/topology/IBasicBolt.java
index 1a2d82a..6b580c4 100644
--- a/storm-compatibility/v2.2.0/src/java/org/apache/storm/topology/IBasicBolt.java
+++ b/storm-compatibility/v2.2.0/src/java/org/apache/storm/topology/IBasicBolt.java
@@ -25,8 +25,7 @@
import org.apache.storm.tuple.Tuple;
public interface IBasicBolt extends IComponent {
- @SuppressWarnings("rawtypes")
- void prepare(Map stormConf, TopologyContext context);
+ void prepare(Map<String, Object> topoConf, TopologyContext context);
/**
* Process the input tuple and optionally emit new tuples based on the input tuple.
diff --git a/storm-compatibility/v2.2.0/src/java/org/apache/storm/topology/base/BaseBasicBolt.java b/storm-compatibility/v2.2.0/src/java/org/apache/storm/topology/base/BaseBasicBolt.java
index eee5fcf..e876ba7 100644
--- a/storm-compatibility/v2.2.0/src/java/org/apache/storm/topology/base/BaseBasicBolt.java
+++ b/storm-compatibility/v2.2.0/src/java/org/apache/storm/topology/base/BaseBasicBolt.java
@@ -29,8 +29,7 @@
private static final long serialVersionUID = 1464223135325402830L;
@Override
- @SuppressWarnings("rawtypes")
- public void prepare(Map stormConf, TopologyContext context) {
+ public void prepare(Map<String, Object> topoConf, TopologyContext context) {
}
@Override
