Storm杂谈之Acker拾趣本文所讲内容并非storm的acker机制，而是讲讲开acker和不开acker的具体区别以及在storm源码中是怎样实现的...
分类：
其他好文 时间：
2015-05-27 22:53:52
阅读次数：
309
Storm里面引入DRPC主要是利用storm的实时计算能力来并行化CPU密集型（CPUintensive）的计算任务。DRPC的stormtopology以函数的参数流作为输入，而把这些函数调用的返回值作为topology的输出流。DRPC其实不能算是storm本身的一个特性，它是通过组合storm的原语stream、spout、bo..
分类：
其他好文 时间：
2015-05-27 19:21:16
阅读次数：
144
Storm里面引入DRPC主要是利用storm的实时计算能力来并行化CPU密集型（CPU
intensive）的计算任务。DRPC的stormtopology以函数的参数流作为输入，而把这些函数调用的返回值作为topology的输出流。
DRPC其实不能算是storm本身的一个特性， 它是通过组合storm的原语stream、spout、bolt、 topology而成的一种模式(pat...
分类：
其他好文 时间：
2015-05-27 19:13:47
阅读次数：
152
Storm里面引入DRPC主要是利用storm的实时计算能力来并行化CPU密集型（CPU intensive）的计算任务。DRPC的stormtopology以函数的参数流作为输入，而把这些函数调用的返回值作为topology的输出流。DRPC其实不能算是storm本身的一个特性， 它是通过组合st...
分类：
其他好文 时间：
2015-05-27 19:02:12
阅读次数：
114
数据模型(DataModel)storm使用tuple来作为它的数据模型。每个tuple是一堆值，每个值有一个名字，并且每个值可以是任何类型，在我的理解里面一个tuple可以看作一个没有方法的java对象。总体来看，storm支持所有的基本类型，字符串以及字节数组作为tuple的值类型。你也可以使用你..
分类：
其他好文 时间：
2015-05-26 19:05:57
阅读次数：
103
数据模型(Data Model)
storm使用tuple来作为它的数据模型。每个tuple是一堆值，每个值有一个名字，并且每个值可以是任何类型， 在我的理解里面一个tuple可以看作一个没有方法的java对象。总体来看，storm支持所有的基本类型，字符串以及字节数组作为tuple的值类 型。你也可以使用你自己定义的类型来作为值类型，
只要你实现对应的序列化器(serializer)。 ...
分类：
其他好文 时间：
2015-05-26 18:54:46
阅读次数：
98
数据模型(Data Model)storm使用tuple来作为它的数据模型。每个tuple是一堆值，每个值有一个名字，并且每个值可以是任何类型， 在我的理解里面一个tuple可以看作一个没有方法的java对象。总体来看，storm支持所有的基本类型，字符串以及字节数组作为tuple的值类 型。你也可...
分类：
其他好文 时间：
2015-05-26 18:34:36
阅读次数：
114
流分组在设计一个topology的时候，你需要做的最重要的事情是定义数据在组件之间怎样交换(流怎样被bolts消费)。流分组指定了每个bolt消费哪些流和这些流被怎样消费。一个结点可以发射不止一条数据流。流分组允许我们选择接收哪些流。正如我们在第二章看到的，当topology被定义的..
分类：
其他好文 时间：
2015-05-25 20:36:05
阅读次数：
135
流分组
在设计一个topology的时候，你需要做的最重要的事情是定义数据在组件之间怎样交换(流怎样被bolts消费)。流分组指定了每个bolt消费哪些流和这些流被怎样消费。
一个结点可以发射不止一条数据流。流分组允许我们选择接收哪些流。
正如我们在第二章看到的，当topology被定义的时候流分组就被设置好了：
...
builder.setBolt("word-normal...
分类：
其他好文 时间：
2015-05-25 18:46:40
阅读次数：
151
流分组在设计一个topology的时候，你需要做的最重要的事情是定义数据在组件之间怎样交换(流怎样被bolts消费)。流分组指定了每个bolt消费哪些流和这些流被怎样消费。一个结点可以发射不止一条数据流。流分组允许我们选择接收哪些流。正如我们在第二章看到的，当topology被定义的时候流分组就被设...
分类：
其他好文 时间：
2015-05-25 18:35:17
阅读次数：
121
