[incubator-heron] branch master updated: update storm 2.2.0 ISpout open() (#3567)

[yaoli]

This is an automated email from the ASF dual-hosted git repository.

yaoli pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-heron.git


The following commit(s) were added to refs/heads/master by this push:
     new eb5090b  update storm 2.2.0 ISpout open() (#3567)
eb5090b is described below

commit eb5090b51fe6b7f552cdbfdaf964eb80fe65b47f
Author: bed debug <huiju...@users.noreply.github.com>
AuthorDate: Sun Jul 12 01:33:01 2020 -0700

    update storm 2.2.0 ISpout open() (#3567)
    
    * updateispout
    
    * fix-style
    
    * minchange
    
    * updateibolt
    
    Co-authored-by: Huijun Wu <huij...@twitter.com>
---
 storm-compatibility/v2.2.0/src/java/org/apache/storm/spout/ISpout.java | 3 +--
 .../v2.2.0/src/java/org/apache/storm/topology/IBasicBolt.java          | 3 +--
 .../v2.2.0/src/java/org/apache/storm/topology/base/BaseBasicBolt.java  | 3 +--
 3 files changed, 3 insertions(+), 6 deletions(-)

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 @@ public interface ISpout extends Serializable {
    * @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.task.TopologyContext;
 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 @@ public abstract class BaseBasicBolt extends BaseComponent 
implements IBasicBolt
   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