Skip to content
Permalink
Browse files
update storm 2.2.0 ISpout open() (#3567)
* updateispout

* fix-style

* minchange

* updateibolt

Co-authored-by: Huijun Wu <huijunw@twitter.com>
  • Loading branch information
huijunwu and huijunw committed Jul 12, 2020
1 parent 9e0c782 commit eb5090b51fe6b7f552cdbfdaf964eb80fe65b47f
Showing 3 changed files with 3 additions and 6 deletions.
@@ -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
@@ -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.
@@ -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

0 comments on commit eb5090b

Please sign in to comment.