HBase中MVCC的实现机制及应用情况(二)

2015-08-31 20:00:02 · 作者: · 浏览: 134
xt(List outResults, int limit) throws IOException


而上述方法会通过KeyValueHeap的next方法读取下一条数据:先定位到当前KeyValueScanner(即之前构造KeyValueHeap时传入的MemStoreScanner或StoreScanner),然后调用next方法。


StoreFileScanner和MemStoreScanner均为KeyValueScanner,通过其中的next()接口方法,分别调用到StoreFileScanner.java的skipKVsNewerThanReadpoint方法、Memstore.java中MemStoreScanner对象的getNext方法。


1)StoreFileScanner.java的skipKVsNewerThanReadpoint方法:


2)? Memstore.java中MemStoreScanner对象的getNext方法: