当前位置:首页 > windos > 正文

Storm storm API(二)

  1、Spout

  Spout最顶层抽象是ISpout接口。

   Open()是初始化方法

   nextTuple()循环发射数据  

     ack()成功处理tuple回调方法

     fail()处理失败tuple回调方法

     activate和deactivate:spout可以被暂时激活和关闭

   close方法在该spout关闭前执行,但是并不能得到保证其一定被执行,kill -9 时不执行,Storm kill topoName时执行,如图: