Storm storm API(二)

2021-02-04 06:17

阅读:648

标签:close   mic   img   image   activate   方法   height   失败   执行   

  1、Spout

  Spout最顶层抽象是ISpout接口。

   Open()是初始化方法

   nextTuple()循环发射数据  

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

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

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

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

                             技术图片

Storm storm API(二)

标签:close   mic   img   image   activate   方法   height   失败   执行   

原文地址:https://www.cnblogs.com/houstao/p/11473880.html


评论


亲,登录后才可以留言!