Skip to content
This repository was archived by the owner on Mar 3, 2023. It is now read-only.

Commit eb5090b

Browse files
huijunwuhuijunw
andauthored
update storm 2.2.0 ISpout open() (#3567)
* updateispout * fix-style * minchange * updateibolt Co-authored-by: Huijun Wu <[email protected]>
1 parent 9e0c782 commit eb5090b

File tree

3 files changed

+3
-6
lines changed

3 files changed

+3
-6
lines changed

storm-compatibility/v2.2.0/src/java/org/apache/storm/spout/ISpout.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -57,8 +57,7 @@ public interface ISpout extends Serializable {
5757
* @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.
5858
* @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.
5959
*/
60-
@SuppressWarnings("rawtypes")
61-
void open(Map conf, TopologyContext context, SpoutOutputCollector collector);
60+
void open(Map<String, Object> conf, TopologyContext context, SpoutOutputCollector collector);
6261

6362
/**
6463
* Called when an ISpout is going to be shutdown. There is no guarentee that close

storm-compatibility/v2.2.0/src/java/org/apache/storm/topology/IBasicBolt.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -25,8 +25,7 @@
2525
import org.apache.storm.tuple.Tuple;
2626

2727
public interface IBasicBolt extends IComponent {
28-
@SuppressWarnings("rawtypes")
29-
void prepare(Map stormConf, TopologyContext context);
28+
void prepare(Map<String, Object> topoConf, TopologyContext context);
3029

3130
/**
3231
* Process the input tuple and optionally emit new tuples based on the input tuple.

storm-compatibility/v2.2.0/src/java/org/apache/storm/topology/base/BaseBasicBolt.java

+1-2
Original file line numberDiff line numberDiff line change
@@ -29,8 +29,7 @@ public abstract class BaseBasicBolt extends BaseComponent implements IBasicBolt
2929
private static final long serialVersionUID = 1464223135325402830L;
3030

3131
@Override
32-
@SuppressWarnings("rawtypes")
33-
public void prepare(Map stormConf, TopologyContext context) {
32+
public void prepare(Map<String, Object> topoConf, TopologyContext context) {
3433
}
3534

3635
@Override

0 commit comments

Comments
 (0)