storm-kafka KafkaSpout原理分析

10-06 3,186 views

Storm Spout 通过实现Storm中的ISpout接口,重写其中的nextTuple、ack和fail方法,可以实现tuple流的发送、成功确认、失败重发。ISpout接口代码如下所示。 ...
阅读全文 0

使用daemontools实现Storm进程监控

10-01 2,420 views

Storm集群如图所示: 其中包含一个nimbus节点和多个supervisor节点: 1)nimbus,负责在集群中分发代码,分配计算任务,监控失败等; 2)supervisor,负责在...
阅读全文 0

storm读书笔记

8-15 1,125 views

什么是storm 分布式实时计算系统; 与hadoop为批处理提供map和reduce这两种操作原语类似,storm为实时处理也提供了spout和bolt这两种操作原语; storm的特点...
阅读全文 0