JStorm源代码阅读——顶层设计
最让人困惑就是IBasic和IBoltIBot和两给类。区别在于一个要求在pepare阶段传入OutputCollector,而另一个则在execute阶段。
public interface IBasicBolt extends IComponent {
void prepare(Map stormConf, TopologyContext context);
/**
* Process the input tuple and optionally emit new tuples based on the input tuple.
*
* All acking is managed for you. Throw a FailedException if you want to fail the tuple.
*/
void execute(Tuple input, BasicOutputCollector collector);
void cleanup();
}
public interface IBolt extends Serializable {
/**
* Called when a task for this component is initialized within a worker on the cluster. It provides the bolt with the environment in which the bolt
* executes.
*
* <p>
* This includes the:
* </p>
*
* @param stormConf The Storm configuration for this bolt. This is the configuration provided to the topology merged in with cluster configuration on this
* machine.
* @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 bolt. Tuples can be emitted at any time, including the prepare and cleanup methods. The
* collector is thread-safe and should be saved as an instance variable of this bolt object.
*/
void prepare(Map stormConf, TopologyContext context, OutputCollector collector);
/**
* Process a single tuple of input. The Tuple object contains metadata on it about which component/stream/task it came from. The values of the Tuple can be
* accessed using Tuple#getValue. The IBolt does not have to process the Tuple immediately. It is perfectly fine to hang onto a tuple and process it later
* (for instance, to do an aggregation or join).
*
* <p>
* Tuples should be emitted using the OutputCollector provided through the prepare method. It is required that all input tuples are acked or failed at some
* point using the OutputCollector. Otherwise, Storm will be unable to determine when tuples coming off the spouts have been completed.
* </p>
*
* <p>
* For the common case of acking an input tuple at the end of the execute method, see IBasicBolt which automates this.
* </p>
*
* @param input The input tuple to be processed.
*/
void execute(Tuple input);
/**
* Called when an IBolt is going to be shutdown. There is no guarentee that cleanup will be called, because the supervisor kill -9's worker processes on the
* cluster.
*
* <p>
* The one context where cleanup is guaranteed to be called is when a topology is killed when running Storm in local mode.
* </p>
*/
void cleanup();
}
Storm的设计者希望
如果使用IBasicBolt 不需要手动调用ack方法
如果使用IRichBolt 手动调用ack方法
我们再上面图中补齐一些其他的关系。发现实际上对Bisicbolt实际上是转化为richbolt。