在storm 之中,spout 和Bolt 都是其Compnent, 所以在Storm之中定义了一个名叫 IComponent
的总接口
Spout
在前面的基本例子中,我们实现了一个RandomSout,来看看其类图
Spout的最顶级的抽象是ISpout接口
有关如下的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的类图
Ibolt 继承了java.io.Serializable 我们在nimbus上提交了topology
execute 接受一个tuple进行处理,并在prepare 方法传入的 ACK方法,或者fail方法表示来反馈处理的结果
通常情况之下,他实际上相当于自动做掉prepare方法和collector.emit.ack(inputTupe)
到此,相信大家对“Spout的相关知识点有哪些”有了更深的了解,不妨来实际操作一番吧!这里是本站网站,更多相关内容可以进入相关频道进行查询,关注我们,继续学习!
本文由 贵州做网站公司 整理发布,部分图文来源于网络,如有侵权,请联系我们删除,谢谢!
抖音(Tiktok)是由北京字节跳动科技有限公司(ByteDance)孵化的音乐创意短视频社交网站。它于2016年9月20日上线,主要面向全年龄段的用户,尤其是...
飞极速为您提供高清在线电影、电视剧大全、动画片,综艺等,飞极速在线更新及时,播放速度快,给您带来最好的观影体验!飞极速在线,免费提供日本新番动漫、最新电影和最新...
《南华早报》(英语:South China Morning Post, SCMP)和星期日出版的《星期日南华早报》(英语:Sunday Morning Post...
11月12日,德云社在孟鹤堂三里屯演出,下午与搭档周九良担纲“救底”,为观众带来作品《口吃论》。看到小剧场门口大量的鲜花和公仔板,有朋友感慨道,粉丝的支持力度真的很强大,萌哥的热度真的让人羡慕。当然,看到作品名字后,有朋友说,孟在作品的选择上也是很用心的,他已经很久没有登台了。如果有一个“口吃”来掩盖卡住的地方,也不会影响大家的观感。对于孟,,很多朋友都喜欢和支持他。当你坚守小剧场的时候,你可以把...
(相关资料图)1、还不错的景点挺好玩。2、下水瀑布位于那播村委会下水村,从马吊苏山上方波澜不惊地注入水潭中,再缓缓流入山涧声势夺人,涧下怪石密布,姿态万千;周围方圆数百里树海郁郁葱葱、密密麻麻。3、沿着瀑布左侧小径走到瀑布上方,居然别有洞天。4、在树海山涧掩映之下,又是一条飞流入涧的树海瀑布,感叹大自然的鬼斧神工。以上就是【魔力宝贝树海任务攻略,树海瀑布】相关内容。...
国投发债于8月20日上市进行交易,债券代码为1 10073,债券简称为国投转债,申购代码为733061, 申购简称为国投发债,原股东配售认购简称为国投配债。国投发债是指国投资本股份有限公司公开发行的可转换公司债券。国投资本股份有限公司的股票为国投资本,股票代码为: 600061。国投资本股份有限公司最早成立于1997年并于同年5月在上海证券交易所上市,成立时名称为中纺投资发展股份有限公司。2015...