HBase源码阅读资源

  1. 云栖社区>
  2. 博客>
  3. 正文

HBase源码阅读资源

cloudcoder 2016-05-13 14:19:28 浏览1699
展开阅读全文

HBase MemStoreFlusher

虽与最新版0.98.7的实现已经有差异,但分析的比较好

MemeStoreFlusher在HRegionServer类中初始化。

HRegionServer实现了Runnable接口,在run方法中针对MemeStoreFlusher进行了初始化

 private void initializeThreads() throws IOException {
    // Cache flushing thread.
    this.cacheFlusher = new MemStoreFlusher(conf, this);
    ...
    }
    
    启动:
    this.cacheFlusher.start(uncaughtExceptionHandler);
    interrupt:
    if (this.cacheFlusher != nullthis.cacheFlusher.interruptIfNecessary();

网友评论

登录后评论
0/500
评论
cloudcoder
+ 关注