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做了比较大的调整, 比较突出的是更换了几乎所有 ...