storm trident定义的内存结构MemoryMapState 详解
storm trident定义的内存结构MemoryMapState 详解
岩之有理 发表于3年前
storm trident定义的内存结构MemoryMapState 详解
  • 发表于 3年前
  • 阅读 72
  • 收藏 0
  • 点赞 0
  • 评论 0

标题:腾讯云 新注册用户域名抢购1元起>>>   

摘要: MemoryMapState 是trident中定义的一种state,用来保存storm trident算出的数据。也提供查询

MemoryMapState trident中定义的一种state,用来保存storm trident算出的数据。

看一下MemoryMapState 和 State的关系


MemoryMapState 将所有的数据存放在内部静态属性

 static ConcurrentHashMap<String, Map<List<Object>, Object>> _dbs = new ConcurrentHashMap<String, Map<List<Object>, Object>>();

关于ConcurrentHashMap,可以当作一个线程安全的map

public class ConcurrentHashMap<K, V> extends AbstractMap<K, V> 
implements ConcurrentMap<K, V>, Serializable

MemoryMapState 对ConcurrentHashMap的操作,主要依靠内部类 MemoryMapStateBacking进行。

static class MemoryMapStateBacking<T> implements IBackingMap<T>, ITupleCollection

storm学到现在,感觉里面都是套子,一个类的方法其实是调用自己一个属性的方法,很多层。


共有 人打赏支持
粉丝 7
博文 18
码字总数 6134
×
岩之有理
如果觉得我的文章对您有用,请随意打赏。您的支持将鼓励我继续创作!
* 金额(元)
¥1 ¥5 ¥10 ¥20 其他金额
打赏人
留言
* 支付类型
微信扫码支付
打赏金额:
已支付成功
打赏金额: