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
