详细介绍如何自定义KafkaSpout发射的message...
分类:
其他好文 时间:
2014-11-08 15:21:19
阅读次数:
174
详细分析了KafkaSpout的一些代码,希望能够帮助一下人,同时也是自己看代码的一个总结。...
分类:
Web程序 时间:
2014-11-08 15:20:40
阅读次数:
518
上一节介绍了config的相关信息,这一节说下如何创建一个KafkaSpout而已...
分类:
Web程序 时间:
2014-11-08 15:19:01
阅读次数:
311
Async loop died! 重启任务后发现任务一直异常,日志中有大量reconnect。 b.s.m.n.Client [INFO] Reconnect started for Netty-Client-192.168.1.2/192.168.1.21:6724... [26] telnet到对应级机器的6724端口,连接...
分类:
其他好文 时间:
2014-11-07 15:10:50
阅读次数:
127
storm实时处理实例设计方案,为初学者提供一个相对容易理解的实例。...
分类:
其他好文 时间:
2014-11-06 22:03:30
阅读次数:
241
public class HBaseBolt extends BaseRichBolt {...}public class SenqueceBolt extends BaseBasicBolt {...}在一个TaskTopology中用了上面两种Bolt出现循环执行Topology解决: 继承同....
分类:
其他好文 时间:
2014-11-05 18:58:45
阅读次数:
145
一个更复杂的例子上面的DRPC例子只是为了介绍DRPC概念的一个简单的例子。下面让我们看一个复杂的、确实需要storm的并行计算能力的例子, 这个例子计算twitter上面一个url的reach值。首先介绍一下什么是reach值,要计算一个URL的reach值,我们需要:获取所有微薄里面包含这个UR...
分类:
其他好文 时间:
2014-11-03 22:22:27
阅读次数:
219
Storm-源码分析汇总Storm FeaturesStorm 简介Storm Topology的并发度Storm - Guaranteeing message processingStorm - Transactional-topologiesTwitter Storm – DRPCStorm 多...
分类:
其他好文 时间:
2014-11-01 14:37:40
阅读次数:
532
后面为了引入Dubbo RPC框架(用spring配置),先把spring 引入jstorm中,请先了解一下jsorm多线程方面的文档:http://storm.apache.org/documentation/Understanding-the-parallelism-of-a-Storm-topology.html .
A worker process exe...
分类:
编程语言 时间:
2014-10-30 22:43:42
阅读次数:
517
拓扑学(TOPOLOGY)是一种研究与大孝距离无关的几何图形特性的方法,起初它是几何学的一支,研究几何图形在连续变形下保持不变的性质。而由此衍伸出来的拓扑图就是借图形显示量化信息。拓扑图一般用于计算机网络示意,也就是不考虑计算机实际的位置,只表示网络中每台计算机以..
分类:
其他好文 时间:
2014-10-30 19:22:36
阅读次数:
214