此案例实现从数组中随机读取字符串发送到bolt，bolt将字符串变成大写发送到下一个bolt，bolt将字符串加上时间戳然后写到文件中
public class RandomWordSpout extends BaseRichSpout {
/**
* 数据源
*/
private static final long serialVersionUID = 1L;
private S...
分类：
其他好文 时间：
2016-05-12 16:43:43
阅读次数：
150
背景: 最近看到一篇文章说twitter内部已经用heron代替storm了,so ...带着好奇心,看了一篇两者的对比.文章前半部分说storm现在遇到的困难.包括:日志的定位,内存资 源的分配,nimbus单点问题以及瓶颈, bolt缺少背压机制等等...在评估和各种条件下,twitter团队决 ...
流分组为每一个Bolt指定应该接受哪个流作为输入，定义了流/元组如何让在Bolt的任务之间进行分发。 在设计拓扑的时候，需要做一件非常重要的事情，就是定义数据如何在组件之间进行的交换。一个流分组指定每个Bolt消耗哪个流，流将如何被消耗。一个节点可以发出许多流，流分组允许我们有选择地接受流。 Sto ...
分类：
其他好文 时间：
2016-04-15 10:35:58
阅读次数：
262
storm集群中的一台机器可能运行着一个或者多个worker进程，其从属于一个或者多个topology。一个worker进程运行着多个executor线程；每一个worker从属于一个topology；executor是单线程，每一个executor运行着相同组件(spout或者bolt)的1个或者
分类：
其他好文 时间：
2016-03-18 17:51:15
阅读次数：
194
storm的并发机制 storm计算支持在多台机器上水平扩容，通过将计算切分为多个独立的tasks在集群上并发执行来实现。 一个task可以简单地理解：在集群某节点上运行的一个spout或者bolt实例。 topology的组成部分：Nodes(服务器):配置在一个storm集群中的服务器，会执行t
分类：
其他好文 时间：
2016-03-09 20:41:04
阅读次数：
164
使用其他语言编写Bolt Bolt可以使用任意语言编写。用另外一种语言编写Bolt来作为子进程运行。Storm会在标准输入输出的基础上使用Json来与子进程通信。通信协议之需要一个100行的适配器库，Storm自带了Ruby,Python,和Fancy的适配器库。 下面是WordCountTopol
分类：
其他好文 时间：
2016-03-07 01:15:14
阅读次数：
221
参考链接：http://xumingming.sinaapp.com/811/twitter-storm-code-analysis-coordinated-bolt/ CoordinatedBolt是非常关键的一个类，它用于协调系统中的Bolt节点。对于事务Topology中的Bolt节点，若能知...
分类：
数据库 时间：
2016-02-14 22:18:51
阅读次数：
274
ITransactionalSpout 基本事务Topology的Spout接口，内含两部分接口：协调Spout接口以及消息发送Blot接口。 TransactionalSpoutBatchExecutor Bolt类型，用于执行ITransactionalSpout中的消息发送Bolt节点。 Tr...
分类：
其他好文 时间：
2016-02-13 12:18:01
阅读次数：
222
工作进程(Worker Process) Worker是Spout/Bolt中运行具体处理逻辑的进程。拓扑跨一个或多个Worker进程执行。每个Worker进程是一个物理的JVM和拓扑执行所有任务的一个子集。例如，如果合并并行度的拓扑是300，已经分配50个Worker，然后每个Worker将执行6
分类：
其他好文 时间：
2016-01-31 21:19:57
阅读次数：
263
有了基本的概念之后，我们用jstorm来做一点小事情吧 做一个很无聊的事情：给定一个时间戳，输出对应的问候语 规则是：时间戳的十位对应的数字对应不同的时间段，0-2代表早上，3代表中午，4-6代表下午，7-9代表晚上，分别输出早上，中午，下午和晚上。 我们用spout来发送时间戳，bolt来处理时间
分类：
Web程序 时间：
2016-01-30 22:40:21
阅读次数：
373
