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包 主类名)
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包 主类名)
相关文章推荐
- Effective C ++ 条款34
- Windows编程陷阱之 *
- Ural 1018 binary apple tree(显性树的树dp)
- PHP面向过程方式操作数据库(扩展增强库MySQLi)
- python str.translate()函数用法
- wpf任务
- Couchbase View
- 【整理】队列特征以及代码的实现
- 修改Fedora10显示语言
- Binary Tree Level Order Traversal II
- Android CTS 测试总结【转】
- 安装vnc
- 仅为了方便以后提交审核的时候能有参考
- Java 虚拟机
- 反射之简单实例
- App installation failed There was an internal API error.
- 自测3. 数组元素循环右移问题
- php转json格式出现中文的解决办法
- 第五次作业
- 指针1