storm中bolt接收数据
2015-07-20 20:35
477 查看
在storm中的bolt,是一个处理数据的单元,bolt中主要的方法execute(Tuple t,collector c){}
在方法中通过t.getStringByField("str"),这个str就是在spout和bolt在进行发射数据的时候进行声明的:
word就是以后再bolt中去取的str.
在方法中通过t.getStringByField("str"),这个str就是在spout和bolt在进行发射数据的时候进行声明的:
public void declareOutputFields(OutputFieldsDeclarer declarer) { | |
declarer.declare(new Fields("word")); | |
} |
相关文章推荐
- Android50道面试题
- android代码控制seekbar的样式
- POJ 2752 Seek the Name, Seek the Fame(KMP)
- Cocos2dx 2.x 安卓重力检测 旋转屏幕
- Java NIO原理图文分析及代码实现
- 锁屏效果
- 如何在Spring加载bean之前设置系统属性
- linux常用命令
- 第五天 类和对象
- Divisibility by Eight
- Unity退出后保存数据,PlayerPrefs 玩家偏好
- [UVA400]Unix ls[格式输出]
- B 类 对象 继承 多态与动态绑定
- 高阶函数 Higher-order function
- 简述系统调用的执行过程?
- 交互模式下python自动补全
- UVA 401
- 欢迎使用CSDN-markdown编辑器
- 利用inotify+rsync实现linux文件批量更新
- c++string