数据模型(Data Model)

时间：2015-05-26 18:54:46 阅读：98 评论：0 收藏：0 [点我收藏+]

数据模型(Data Model)
storm使用tuple来作为它的数据模型。每个tuple是一堆值，每个值有一个名字，并且每个值可以是任何类型，在我的理解里面一个tuple可以看作一个没有方法的java对象。总体来看，storm支持所有的基本类型，字符串以及字节数组作为tuple的值类型。你也可以使用你自己定义的类型来作为值类型，只要你实现对应的序列化器(serializer)。
topology里面的每个节点必须定义它要发射的tuple的每个字段。比如下面这个bolt定义它锁发射的tuple包含两个字段，类型分别是: doble和triple。

publicclass DoubleAndTripleBolt implements IRichBolt { private OutputCollectorBase _collector;    @Override
publicvoid prepare(Map conf, TopologyContext context, OutputCollectorBase collector){
      _collector = collector; }
   @Override
publicvoid execute(Tuple input){ int val = input.getInteger(0);
      _collector.emit(input, new Values(val*2, val*3));       _collector.ack(input); }
   @Override
publicvoid cleanup(){ }
   @Override
publicvoid declareOutputFields(OutputFieldsDeclarer declarer){
declarer.declare(new Fields("double", "triple")); } }

declareOutputFields方法定义要输出的字段： ["double", "triple"]。这个bolt的其它部分我们接下来会解释。

更多精彩内容请关注：http://bbs.superwu.cn

关注超人学院微信二维码：技术分享

数据模型(Data Model)

标签：storm 超人学院 hadoop

原文地址：http://blog.csdn.net/crxy2014/article/details/46010123

踩

(0)

评论一句话评论（0）

分享档案

更多>

2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)

周排行