AI
推荐
模板社区
专题
登录
免费注册
首页
流程图
详情
storm代码处理流程
2020-03-06 08:14:09
16
举报
分享方式
免费使用
stormWordCount代码流程
Storm
模版推荐
作者其他创作
大纲/内容
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\")
收藏
立即使用
storm代码处理流程
职业：本科
去主页
Collect
Get Started
git代码分支管理规范
Collect
Get Started
代码定位
Collect
Get Started
Storm架构图
Collect
Get Started
storm
评论
0
条评论
下一页
Document
