Storm常見模式——TimeCacheMap
Storm中使用一種叫做TimeCacheMap的數據結構，用於在內存中保存近期活躍的對象，它的實現非常地高效，而且可以自動刪除過期不再活躍的對象。 TimeCacheMap使用多個桶buckets來縮小鎖的粒度，以此換取高並發讀寫性能。下面我們來看看TimeCacheMap內部是如何實現 ...
原文：Storm TimeCacheMap RotatingMap源碼分析
TimeCacheMap是Twitter Storm里面一個類， Storm使用它來保存那些最近活躍的對象，並且可以自動刪除那些已經過期的對象。 不過在storm . 之后TimeCacheMap被棄用了，取而代之的是RotatingMap。 RotatingMap與TimeCacheMap的區別如下： .前者去掉了自動清理的線程，讓用戶自己去控制清理過期的數據，控制清理數據用rotate 方法 ...
2014-04-20 20:41 0 3494 推薦指數：
相關推薦
探索c#之storm的TimeCacheMap
閱讀目錄： 概述 算法介紹 清理線程 獲取、插入、刪除 總結 概述 最近在看storm，發現其中的TimeCacheMap算法設計頗為高效，就簡單分享介紹下。 思考一下如果需要一個帶過期淘汰的緩存容器，我們通常會使用定時器或線程去掃描容器，以便判斷是否過期從而刪除 ...
Storm-源碼分析- metric
首先定義一系列metric相關的interface, IMetric, IReducer, ICombiner (backtype.storm.metric.api) 在task中, 創建一系列builtin-metrics ...
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-源碼分析- Storm中Zookeeper的使用
在backtype.storm.cluster.clj中, 定義了storm對於Zookeeper的使用 ClusterState 首先定義操作Zookeeper集群的interface 實現和生成用於操作Zookeeper集群的record 首先創建 ...
Storm-源碼分析- Scheduler (backtype.storm.scheduler)
首先看看IScheduler接口的定義, 主要實現兩個接口, prepare和schedule 對於schedule的參數注釋寫的非常清楚, topologies包含所有topology的靜態信息, ...
Storm-源碼分析- Disruptor在storm中的使用
Disruptor 2.0, (http://ifeve.com/disruptor-2-change/) Disruptor為了更便於使用, 在2.0做了比較大的調整, 比較突出的是更換了幾乎所有 ...