Storm storm API

Posted houstao

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了Storm storm API相关的知识,希望对你有一定的参考价值。

  1、Spout

  Spout最顶层抽象是ISpout接口。

   Open()是初始化方法

   nextTuple()循环发射数据  

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

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

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

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

                             技术图片

以上是关于Storm storm API的主要内容,如果未能解决你的问题,请参考以下文章

安装配置storm 第二步 配置Storm集群

Storm篇--Storm基础概念

Storm 系列—— Storm 集成 Redis 详解

大数据(十四) - Storm

Storm系列二: Storm拓扑设计

Storm官方文档翻译之创建Storm项目