Spout的相关知识点有哪些

本篇内容主要讲解“Spout的相关知识点有哪些”,感兴趣的朋友不妨来看看。本文介绍的方法操作简单快捷,实用性强。下面就让小编来带大家学习“Spout的相关知识点有哪些”吧!

创新互联公司主要业务有网站营销策划、网站设计、做网站、微信公众号开发、小程序制作、H5页面制作、程序开发等业务。一次合作终身朋友,是我们奉行的宗旨;我们不仅仅把客户当客户,还把客户视为我们的合作伙伴,在开展业务的过程中,公司还积累了丰富的行业经验、全网整合营销推广资源和合作伙伴关系资源,并逐渐建立起规范的客户服务和保障体系。 

Component

在Storm 之中,Spout 和Bolt 都是其Compnent, 所以在Storm之中定义了一个名叫 IComponent

的总接口

Spout

在前面的基本例子中,我们实现了一个RandomSout,来看看其类图

Spout的相关知识点有哪些

Spout的最顶级的抽象是ISpout接口

Spout的相关知识点有哪些

有关如下的API  

1:oepn 方法是初始化动作: 允许你在该spout 初始化时做一些动作,传入了上写文,也方便娶上下文的一些数据

2 :close 方法在该Spout 关闭前执行,但是并不能得到保证其一定会执行,spout是作为task 运行,在worker内的,在

clouster 集群之下,我们的 supervisor 会直接kill掉 ,这样它就有可能不会允许, 而在本地的模式之下,只要不是kill -9,如果是发送停止命令,是可以保证close的执行的。

3 : Activate

4 :deactivate

5: nextTuple                       : nextTuple 用来发送数据

6 ack ( Object )                   : Ack 传入的Object其实是一个id. 表示唯一一个tuple 

7 fail ( Object )

由于继承了BaseRichSpout, 所以不用实现 close,activate,deactivate,ack,fail

等方法。

结论:

        在通常的情况之下,(Shel 和事物型的除外),实现一个Spout,可以直接的去实现IRichSpout

如果不想写IRIchSpout代码,可以继承自BaseRichSpout

Bolt

ExclaimBasicBolt的类图

Spout的相关知识点有哪些

Ibolt 继承了java.io.Serializable 我们在nimbus上提交了topology

execute 接受一个tuple进行处理,并在prepare 方法传入的 ACK方法,或者fail方法表示来反馈处理的结果

通常情况之下,他实际上相当于自动做掉prepare方法和collector.emit.ack(inputTupe)

到此,相信大家对“Spout的相关知识点有哪些”有了更深的了解,不妨来实际操作一番吧!这里是创新互联网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!


标题名称:Spout的相关知识点有哪些
网站网址:http://pwwzsj.com/article/gopcji.html