一、Storm中运行的组件
我们知道，Storm的强大之处就是可以很容易地在集群中横向拓展它的计算能力，它会把整个运算过程分割成多个独立的tasks在集群中进行并行计算。在Storm中，一个task就是运行在集群中的一个Spout或Bolt实例。
为了方便理解Storm如何并行处理我们分给它的任务,这里我先介绍一下在集群中涉及到Topology的四种组件：
...
分类：
其他好文 时间：
2014-11-13 16:35:06
阅读次数：
266
public class HBaseBolt extends BaseRichBolt {...}public class SenqueceBolt extends BaseBasicBolt {...}在一个TaskTopology中用了上面两种Bolt出现循环执行Topology解决： 继承同....
分类：
其他好文 时间：
2014-11-05 18:58:45
阅读次数：
145
流程：1.X端发送数据到kafka（如web端发送的订单数据）。2.storm从kafka获取数据进行分析。 a.storm与kafka整合，获得数据——Sport b.storm对数据进行分析——Bolt 3.结果保存和显示（或者传给别人）。 a.将结果保存到DB（Hbase，redi...
分类：
其他好文 时间：
2014-10-25 17:13:49
阅读次数：
220
在storm中的Bolt中可以处理完成逻辑后，向后面的Blot继续发送消息。可以发送多个不同的消息，如：collector.emit("update-delivered-status",new Values(emailDeliverStatus)); collector.emit("save-...
分类：
其他好文 时间：
2014-10-24 12:44:07
阅读次数：
313
上篇文章本人简单的介绍了Storm的起源，今天本人又继续学习了Storm的基本的一些知识，基本了解了他的基本用法，还好，不算太难，如果大家了解了Hadoop的MapReduce模型的话，看这个也是非常类似的。在了解Storm的原型时，首先了解一些概念。
1.Tuple(元组)，作为消息传递的基本单元，元组中的字段可以是任何类型的对象。元组会用于后面提到的Bolt方法的execute方法。
2....
分类：
其他好文 时间：
2014-10-22 11:10:34
阅读次数：
212
过程,Spout 发送msgid 1-10一级Bolt， msgid1的tuple做为基本组合tuple, 其他8个和一组合, 然后发送给二级Bolt， 同时单个msgid对应的tuple都ack一次，msgid1对象tuple, acker将会跟踪8个二级bolt处理情况.二级Bolt，发送ack...
分类：
其他好文 时间：
2014-10-03 23:48:05
阅读次数：
503
火焰的图片我是没找到，找到了几张雷电的，就在d3dcoder.net 的directx10那本书代码下载的Bolt Animations for Chapter 9 里面
里面很多张图片，由于c++也是初学，一时来不及弄字符串拼接的函数。 只能定义很多个帧bmp 然后一个一个载入了
具体代码是建立在那个"crate" 例子工程， 就是那个木箱子的代码基础上。
添加的代码如下:
I...
分类：
其他好文 时间：
2014-09-22 00:59:31
阅读次数：
258
阅读背景： ? ?1 ： 您需要对滑动窗口要初步了解 ? ?2 ?: ? 您需要了解滑动窗口在滑动的过程之中，滑动chunk的计算过程，尤其是每发射一次，就需要清空一次。 package?com.cc.storm.bolt;
import?java....
分类：
其他好文 时间：
2014-09-03 19:58:17
阅读次数：
289
几个开源的DirectUI库1.DirectUI----------一个外国人写的库，好像很多库都以此为基础。2.DuiLib------------国人写的库，源自DirectUI库，听说修改了很多bug增加了功能3. 迅雷Bolt界面库----------迅雷公司开源的迅雷使用的界面库。4.金山...
分类：
编程语言 时间：
2014-08-29 17:41:48
阅读次数：
621
Nimbus ：负责资源分配和任务调度, 把任务相关的元信息写入Zookeeper 相应目录。
Supervisor ：负责接受nimbus 分配的任务，启动和停止属于自己管理的worker 进程。
Worker ：运行具体处理组件逻辑的进程。
Executor ：运行spout/bolt 的线程
Task ： worker 中每一个spout/bolt 的线程称为一个task.
Topology ： storm 中运行的实时应用程序，消息在各个组件间流动形成逻辑上的拓扑结构。
Spout ：在一个topo...
分类：
其他好文 时间：
2014-08-20 12:39:12
阅读次数：
171
