master
:有且仅有一个;Nimbus
:master节点运行的后台,他发现一个worker node挂掉的时候,会自动重启它;Supervisor
:worker node运行的后台,与Nimbus通信通过Zookeeper declareOutputFields:定义传送tuple中值的名字
open:连接数据源,获取数据
nextTuple:当storm已经练接好数据源,它来发送数据到下游
SpoutOutputCollector:发送tuple,处理失败的tuple
复制代码
exetute:处理上游tuple,并发送tuple到下游,一个bolt的实例,它的
execute方法每次只处理一个tuple
prepare:初始化时候用
BasicOutputCollector:发送tuple,处理失败的tuple
复制代码
本文来自<Storm实战>。推荐。这本书可以基本理解storm。