Bolt接口各个方法的执行顺序
在storm-user中看到的一个关于StormBolt内部实现的执行顺序的提问,觉得对理解Bolt内部实现有帮助,记录一下.
prepare方法在worker初始化task的时候调用.
execute方法在每次有tuple进来的时候被调用
cleanup实际上仅用于本地模式(localmode),在集群模式(clustermode)下该方法很难保证每次被正确执行.
declearOutputFields方法仅在有新的topology提交到服务器,用来决定输出内容流的格式(相当于定义spout/bolt之间传输stream的name:value格式),在topology执行的过程中并不会被调用.
相关推荐
huimeiad 2020-11-23
往后余生 2020-09-17
hushijiao 2020-11-10
lxhuang 2020-11-03
womystery 2020-10-15
Martian 2020-10-13
luguanyou 2020-10-05
夜影风个人空间 2020-09-22
哈嘿Blog 2020-09-08
LittleCoder 2020-09-11
0linker 2020-09-01
libaoshan 2020-09-11
saluzirobot 2020-09-01
txq0 2020-08-24
充满诗意的联盟 2020-08-23
jaybeat 2020-08-20
浪味仙 2020-08-17
ChinaJoeEE 2020-08-16
jbossrobbie 2020-08-16