Storm-源码分析- Storm中Zookeeper的使用
在backtype.storm.cluster.clj中, 定义了storm对于Zookeeper的使用 ClusterState 首先定义操作Zookeeper集群的interface 实现和生成用于操作Zookeeper集群的record 首先创建 ...
原文：Storm-源码分析- Disruptor在storm中的使用
Disruptor . , http: ifeve.com disruptor change Disruptor为了更便于使用, 在 . 做了比较大的调整, 比较突出的是更换了几乎所有的概念名 老版本, 新版本, 从左到右的变化如下, . Producer gt Publisher . ProducerBarrier被integrate到RingBuffer里面, 叫做PublishPort, 提 ...
2013-07-10 16:18 0 4477 推荐指数：
相关推荐
Storm-源码分析- Thrift的使用
1 IDL 首先是storm.thrift, 作为IDL里面定义了用到的数据结构和service 然后backtype.storm.generated, 存放从IDL通过Thrift自动转化成的Java代码 比如对于nimbus service 在IDL的定义为, 而对 ...
Storm-源码分析- metric
首先定义一系列metric相关的interface, IMetric, IReducer, ICombiner (backtype.storm.metric.api) 在task中, 创建一系列builtin-metrics ...
Storm-源码分析- Scheduler (backtype.storm.scheduler)
首先看看IScheduler接口的定义, 主要实现两个接口, prepare和schedule 对于schedule的参数注释写的非常清楚, topologies包含所有topology的静态信息, 而cluster中包含了topology的运行态信息 根据他们就可以来判断 ...
Storm-源码分析- spout (backtype.storm.spout)
, 但是如果不指定或将message-id置空, storm就不会track这个message 必须要注意 ...
Storm-源码分析-Stats (backtype.storm.stats)
会发现, 现在storm里面有两套metrics系统, metrics framework和stats framework 并且在所有地方都是同时注册两套, 貌似准备用metrics来替代stats, 但当前版本UI仍然使用stats 这个模块统计的数据怎么被使用, 1. ...
Storm-源码分析-Topology Submit-Nimbus-mk-assignments
什么是executor, 参考Storm-源码分析- Component ,Executor ,Tas ...
Storm-源码分析-Topology Submit-Client
1 Storm Client 最开始使用storm命令来启动topology, 如下 storm jar storm-starter-0.0.1-SNAPSHOT-standalone.jar storm.starter.WordCountTopology 这个storm命令 ...