twitter storm源码走读之3--topology提交过程分析
概要 storm cluster可以想像成为一个工厂，nimbus主要负责从外部接收订单和任务分配。除了从外部接单，nimbus还要将这些外部订单转换成为内部工作分配，这个时候nimbus充当了调度室的角色。supervisor作为中层干部，职责就是生产车间的主任，他的日常工作就是时刻等待着调度 ...
原文：twitter storm源码走读之2 -- tuple消息发送场景分析
欢迎转载，转载请注明出处源自徽沪一郎。本文尝试分析tuple发送时的具体细节，本博的另一篇文章 bolt消息传递路径之源码解读 主要从消息接收方面来阐述问题，两篇文章互为补充。 worker进程内消息接收与处理全景图 先上幅图简要勾勒出worker进程接收到tuple消息之后的处理全过程 IConnection的建立与使用 话说在mk threads :bolt函数的实现中有这么一段代码,其主要功 ...
2013-11-21 22:13 2 2193 推荐指数：
相关推荐
twitter storm源码走读之6 -- Trident Topology执行过程分析
欢迎转载，转载请注明出处，徽沪一郎。 TridentTopology是storm提供的高层使用接口，常见的一些SQL中的操作在tridenttopology提供的api中都有类似的影射。关于TridentTopology的使用及运行原理，当前进行详细分析的文章不多 ...
RocketMQ中Producer消息的发送源码分析
上篇博客介绍过Producer的启动，这里涉及到相关内容就不再累赘了 【RocketMQ中Producer的启动源码分析】 Producer发送消息，首先需要生成Message实例： 其中properties中存放需要配置的属性，由MessageConst规定其key ...
Tigase 发送消息的流程源码分析
XMPP 的<message/>节是使用基本的”push”方法来从一个地方到另一个地方得到消息。因为消息通常是不告知的，它们是一种”fire-and-forget”(发射后自寻目的)的机制来从一个地方到另一个地方快速获取信息 消息节有五种不同的类型，通过 type 属性来进行区分 ...
Twitter 数据实时分析处理工具 Storm
1、简介 Twitter Storm是一个分布式的、容错的实时计算系统，它被托管在GitHub上，遵循 Eclipse Public License 1.0。Storm是由BackType开发的实时处理系统，BackType现在已在Twitter麾下。GitHub上的最新版本是Storm ...
Twitter Storm 实时数据处理框架分析总结
Storm是Twitter开源的一个类似于Hadoop的实时数据处理框架（原来是由BackType开发，后BackType被Twitter收购，将Storm作为Twitter的实时数据分析）。实时数据处理的应用场景很广泛，如上篇文章介绍S4时所说的个性化搜索广告的会话特征分析。而Yahoo当初 ...
Storm-源码分析- metric
首先定义一系列metric相关的interface, IMetric, IReducer, ICombiner (backtype.storm.metric.api) 在task中, 创建一系列builtin-metrics ...
Storm TimeCacheMap RotatingMap源码分析
TimeCacheMap是Twitter Storm里面一个类， Storm使用它来保存那些最近活跃的对象，并且可以自动删除那些已经过期的对象。 不过在storm0.8之后TimeCacheMap被弃用了，取而代之的是RotatingMap。 RotatingMap ...