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 != null) this.cacheFlusher.interruptIfNecessary();
时间: 2024-10-10 15:23:49