首先安装zookeeper集群，然后安装storm集群。 我使用的是centos 32bit的三台虚拟机.
MachineNameipnamenode192.168.99.110datanode01192.168.99.111datanode02192.168.99.112首先配置好ssh,可以无密...
分类：
其他好文 时间：
2015-01-25 19:35:06
阅读次数：
219
这个模式所做的事情概括一下就是把多个不同的任务和操作合并到一个计算单元中，从而使云计算应用提高计算资源利用率，降低管理开销和任务之间连接交互的开销。
PS:我这里对后文中所翻译的“计算单元”做个小小的注释，这里的计算单元可以认为是逻辑的运行容器，可以是基于cgroup的各种container，也可以是像Storm中的worker，Spark中的Executor等等。这个模式除了在自己设计分布式系...
分类：
其他好文 时间：
2015-01-25 12:37:47
阅读次数：
333
TickTuple可以满足每隔一段时间发送tuple，"__system" component会定时往task发送 "__tick" stream的tuple,发送频率由TOPOLOGY_TICK_TUPLE_FREQ_SECS来配置, 可以在default.ymal里面配置,也可以在代码里面通过g...
分类：
其他好文 时间：
2015-01-23 11:08:06
阅读次数：
220
最近在使用storm做一个实时计算的项目,Spout需要从 KAFKA 集群中读取数据，为了提高开发效率，直接使用了Storm提供的KAFKA插件。今天抽空看了一下KafkaSpout的源码，记录下心得体会。 KafkaSpout基于kafka.javaapi.consumer.Simpl...
分类：
Web程序 时间：
2015-01-22 12:47:14
阅读次数：
496
一个topology的启动包括了三个步骤 1)创建TopologyBuilder，设置输入源，输出源 2)获取config 3)提交topology（这里不考虑LocalCluster本地模式） 以storm.starter的ExclamationTopology为例：public static v...
分类：
其他好文 时间：
2015-01-22 12:46:55
阅读次数：
202
Storm-Kafka模块常用接口分析及使用方式,给出具体使用案例...
分类：
其他好文 时间：
2015-01-22 11:08:23
阅读次数：
183
??
1、Trident（三叉戟，开源），IE内核，国内大部分‘壳浏览器’都基于或者兼容该内核，通常适用于国内大部分浏览器的‘兼容浏览器模式’
2、Gecko（壁虎，开源），FireFox内核
3、Webkit(Safari内核,Chrome内核原型,开源):它是苹果公司自己的内核，也是苹果的Safari浏览器使用的内核。国内大部分浏览器的‘极速浏览器模式’使用该内核。
4、Blink，一...
分类：
其他好文 时间：
2015-01-22 01:49:44
阅读次数：
229
1,DRPC原理
客户端给DRPC服务器发送要执行的方法的名字，以及这个方法的参数。实现了这个函数的topology使用DRPCSpout从DRPC服务器接收函 数调用流。每个函数调用被DRPC服务器标记了一个唯一的id。 这个topology然后计算结果，在topology的最后一个叫做ReturnResults的bolt会连接到DRPC服务器，并且把这个调用的结
果发送给DRPC...
分类：
其他好文 时间：
2015-01-21 08:58:57
阅读次数：
134
Avoid The Lakes
Time Limit: 1000MS
Memory Limit: 65536K
Total Submissions: 6409
Accepted: 3466
Description
Farmer John's farm was flooded in the most recent storm, a ...
分类：
其他好文 时间：
2015-01-20 20:37:59
阅读次数：
177
1,报错如下：
ava.lang.RuntimeException: Error when launching multilang subprocess
Caused by: java.io.IOException: Cannot run program "python" (in directory "/tmp/eaf0b6b3-67c1-4f89-b3d8-23edada49b04/super...
分类：
其他好文 时间：
2015-01-20 15:50:56
阅读次数：
251
