storm操作zookeeper的主要函数都定义在命名空间backtype.storm.cluster中(即cluster.clj文件中)。backtype.storm.cluster定义了两个重要protocol:ClusterState和StormClusterState。clojure中的pr...
分类:
其他好文 时间:
2014-08-31 22:51:12
阅读次数:
342
storm操作zookeeper的主要函数都定义在命名空间backtype.storm.cluster中(即cluster.clj文件中)。backtype.storm.cluster定义了两个重要protocol:ClusterState和StormClusterState。clojure中的pr...
分类:
其他好文 时间:
2014-08-31 15:47:41
阅读次数:
184
storm事件管理器定义在event.clj中,主要功能就是通过独立线程执行"事件处理函数"。我们可以将"事件处理函数"添加到EventManager的阻塞队列中,EventManager的事件处理线程不断地从阻塞队列中获取"事件处理函数"并执行。EventManager协议协议就是一组函数定义的集...
分类:
其他好文 时间:
2014-08-31 14:21:21
阅读次数:
219
关于流处理框架,在先前的文章汇总已经介绍过Strom,今天学习的是来自阿里的的流处理框架JStorm。简单的概述Storm就是:JStorm 比Storm更稳定,更强大,更快,Storm上跑的程序,一行代码不变可以运行在JStorm上。...
分类:
Web程序 时间:
2014-08-31 00:34:50
阅读次数:
333
storm操作zookeeper的主要函数都定义在命名空间backtype.storm.cluster中(即cluster.clj文件中)。 backtype.storm.cluster定义了两个重要protocol:ClusterState和StormClusterState。clojure中的p...
分类:
其他好文 时间:
2014-08-30 13:48:29
阅读次数:
154
近期遇到一些同学询问Storm-0.9.2-incubating源代码编译打包的问题,现将编译步骤说明例如以下:1、凝视掉project各pom文件里关于maven插件(maven-gpg-plugin)的内容,目的是规避错误:当然,该错误也能够忽略,即能够不进行上述凝视操作2、在project根文...
分类:
其他好文 时间:
2014-08-29 22:34:08
阅读次数:
300
storm操作zookeeper的主要函数都定义在命名空间backtype.storm.cluster中(即cluster.clj文件中)。backtype.storm.cluster定义了两个重要protocol:ClusterState和StormClusterState。clojure中的pr...
分类:
其他好文 时间:
2014-08-26 22:38:32
阅读次数:
354
在nimbus 节点上执行 “nohup jstorm nimbus &”, 查看$JSTORM_HOME/logs/nimbus.log检查有无错误 在supervisor节点上执行 “nohup jstorm supervisor &”, 查看$JSTORM_HOME/logs/supervisor.log检查有无错误...
分类:
Web程序 时间:
2014-08-26 11:59:36
阅读次数:
427
storm定时器timer源码分析-timer.clj
分类:
其他好文 时间:
2014-08-24 16:34:22
阅读次数:
265
(reify DistributedRPC$Iface (^String execute [this ^String function ^String args] (log-debug "Received DRPC request for " function " " args " at " (Sy...
分类:
其他好文 时间:
2014-08-23 02:14:09
阅读次数:
221