This repository has been archived by the owner on Jun 16, 2023. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 1.8k
IBasicBolt vs IRichBolt
tobecontinued edited this page May 18, 2016
·
5 revisions
事实上,很多使用JStorm/Storm的人无法分清BasicBolt和IRichBolt之间的区别。我们的建议是尽可能的使用IBasicBolt。
IRichBolt继承自IBolt,IBolt会使用OutputCollector来发送元组。
public interface IBolt extends Serializable {
...
void prepare(Map stormConf, TopologyContext context, OutputCollector collector);
...
}
OutputCollector有两个用于发送元组的函数:
//后续component会向acker发送ack响应。
List<Integer> emit(String streamId, Tuple anchor, List<Object> tuple)
//后续component不会向acker发送ack响应。
List<Integer> emit(String streamId, List<Object> tuple) {
IBasicBolt使用BasicOutputCollector来发送元组
public interface IBasicBolt extends IComponent {
...
void execute(Tuple input, BasicOutputCollector collector);
...
}
BasicOutputCollector只有第二个emit函数。但是这个函数包裹了OutputCollector第一个emit函数来完成工作。
//out是一个OutputCollector实例.
List<Integer> emit(String streamId, List<Object> tuple) {
return out.emit(streamId, inputTuple, tuple);
}
因此,在IBasicBolt中,emit(String streamId, List<Object> tuple)
是用于处理元组的可靠方法。但是,在IRichBolt中,它不是一个可靠的方法。
在使用IRichBolt是,如果你想可靠的处理元组,你应该显式地调用emit(String streamId, Tuple anchor, List<Object> tuple)
。