您的位置:首页 > 其它

storm的学习

2015-05-31 10:31 204 查看
1、storm框架的核心:Topology、stream、Spout、Bolt、stream grouping、Task、Worker

2、storm的多语言机制是指可以使用其他的语言定义Spout和Bolt

3、非JVM的语言(比如c++)的Spout和Bolt可以通过一个基于JSON协议的stdin/stdout与storm通信

4、ack方法提供了可靠性机制

5、元组是一个key-list类型,例如定义一个字段 declarer.declare(new Fields("double", "triple"));那么_collector.emit(input, new Values(val*2, val*3));

将val*2发送至"double"的list中,val*3发送至"triple"的list中

6、declarer.shuffleGrouping表示订阅某个Bolt(或Spout)的默认流;fieldsGrouping("BlotA", new Fields("word"))表示订阅组件BoltA的的word分组的数据

7、Spout是数据源,Bolt是处理节点

8、Spout和Bolt共同组成Topology

运行storm的命令:storm jar word-count-1.0.jar WordCountTopolopgyAllInJava (即 storm jar jar包 主类名)
内容来自用户分享和网络整理,不保证内容的准确性,如有侵权内容,可联系管理员处理 点击这里给我发消息
标签: