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命令 ...