Chinaunix首页 | 论坛 | 博客
  • 博客访问: 117149
  • 博文数量: 26
  • 博客积分: 71
  • 博客等级: 民兵
  • 技术积分: 825
  • 用 户 组: 普通用户
  • 注册时间: 2012-11-15 16:14
个人简介

希望在这里与大家一起交流学习,共同进步。。。

文章分类

全部博文(26)

文章存档

2019年(1)

2015年(5)

2014年(6)

2013年(13)

2012年(1)

我的朋友

发布时间:2019-09-23 11:38:41

    想了半天不知道要起一个什么标题,还是沿用老标题吧,没准以后还会有重返之路3、4、5、6、7,哈哈。    看了看之前的博文,发现距离上一次写博文已经4、5年了,工作了也4、5年了,从之前的学生小白变成了油腻大叔了。是不是大多数人工作了以后都不爱写博文了,反正我是基本没写过,都把.........【阅读全文】

阅读(177) | 评论(1) | 转发(0)

发布时间:2015-07-21 12:03:12

有关Storm的ack机制,详情大家可以参考&nbsp; <a target="_blank" href="http://blog.csdn.net/xeseo/article/details/17754825">http://blog.csdn.net/xeseo/article/details/17754825<br /><br /><span style="color:#000000;">在这里只说一下ack的具体实现(当然在这里继承的父类(storm API中的类 如IRichSpout)中不.........【阅读全文】

阅读(1533) | 评论(0) | 转发(0)

发布时间:2015-05-08 20:46:06

storm中要配置并行度,就必须要明白 workers、executors、tasks三个的区别:Workers (JVMs): 在一个节点上可以运行一个或多个独立的JVM 进程。一个Topology可以包含一个或多个worker(并行的跑在不同的machine上), 所以worker process就是执行一个topology的子集, 并且worker只能对应于一个topology;worker processes的数.........【阅读全文】

阅读(5335) | 评论(0) | 转发(0)

发布时间:2015-05-07 22:30:56

1.对storm中传递类型的解释(大家如果不想看也可以直接跳到第二部分,不过看看是很有好处的)大家知道在storm中传递的是tuple,而tuple是没有定义数据类型格式的,也就是tuple是dynamically(动态)类型的,下面解释一下tuple为什么 要定义成动态类型的:一是因为tuple如果定义为静态类型,一定需要定义大量的stormAPI.........【阅读全文】

阅读(2657) | 评论(0) | 转发(0)

发布时间:2015-05-06 22:21:04

storm有多种数据分组策略,但是fieldsGrouping是比较难理解的一种,在这里说一下我的理解fieldsGroup是可以对相同的词进行分组计算,比如有好多词语进行计数,可以用public void declareOutputFields(OutputFieldsDeclarer declarer) {    declarer.declare(new Fields("word"));}这个方法中的”word.........【阅读全文】

阅读(3906) | 评论(0) | 转发(0)
给主人留下些什么吧!~~
留言热议
请登录后留言。

登录 注册