storm代码处理流程
2020-03-06 08:14:09 16 举报
stormWordCount代码流程
作者其他创作
大纲/内容
builder.setSpout(\"RandomSentence”，……）builder.setBolt(\"SplitSentence”，……）builder.setBolt(\"SplitSentence”，……）
nextTuple()
将spout和bolts组合起来
task循环调用nextTuple() 发送数据，形成数据流。spout类是是运行在task中，某个woker进程的某个excutor线程的task中
收到消息后，传入execute（）执行，处理 tuple(word)
WordCount
prepare（）
declareOutputFields（）
继承BaseRichBolt
open()
收到消息后，传入execute（）执行，处理 tuple(sentence)
首要方法，准备发射器(OutputCollector)
定义 发出的tuple名字(\"word\
execute(Tuple tuple)
SplitSentence
定义 发出的tuple名字(\"sentence\")
main
RandomSentenceSpout
初始化spout
定义 发出的tuple名字(\"word\")
收藏
0 条评论
回复 删除
下一页
