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的主要内容,如果未能解决你的问题,请参考以下文章