import org.apache.hadoop.hbase.regionserver.MultiVersionConsistencyControl; //导入依赖的package包/类
/**
 * Do a small get/scan against one store. This is required because store
 * has no actual methods of querying itself, and relies on StoreScanner.
 */
public static List<KeyValue> getFromStoreFile(Store store,
                                              Get get) throws IOException {
  MultiVersionConsistencyControl.resetThreadReadPoint();
  Scan scan = new Scan(get);
  InternalScanner scanner = (InternalScanner) store.getScanner(scan,
      scan.getFamilyMap().get(store.getFamily().getName()));

  List<KeyValue> result = new ArrayList<KeyValue>();
  scanner.next(result);
  if (!result.isEmpty()) {
    // verify that we are on the row we want:
    KeyValue kv = result.get(0);
    if (!Bytes.equals(kv.getRow(), get.getRow())) {
      result.clear();
    }
  }
  scanner.close();
  return result;
}
 

import org.apache.hadoop.hbase.regionserver.MultiVersionConsistencyControl; //导入依赖的package包/类
/**
 * Do a small get/scan against one store. This is required because store
 * has no actual methods of querying itself, and relies on StoreScanner.
 */
public static List<Cell> getFromStoreFile(HStore store,
                                              Get get) throws IOException {
  MultiVersionConsistencyControl.resetThreadReadPoint();
  Scan scan = new Scan(get);
  InternalScanner scanner = (InternalScanner) store.getScanner(scan,
      scan.getFamilyMap().get(store.getFamily().getName()));

  List<Cell> result = new ArrayList<Cell>();
  scanner.next(result);
  if (!result.isEmpty()) {
    // verify that we are on the row we want:
    Cell kv = result.get(0);
    if (!CellUtil.matchingRow(kv, get.getRow())) {
      result.clear();
    }
  }
  scanner.close();
  return result;
}
 

import org.apache.hadoop.hbase.regionserver.MultiVersionConsistencyControl; //导入依赖的package包/类
/**
 * Do a small get/scan against one store. This is required because store
 * has no actual methods of querying itself, and relies on StoreScanner.
 */
public static List<KeyValue> getFromStoreFile(HStore store,
                                              Get get) throws IOException {
  MultiVersionConsistencyControl.resetThreadReadPoint();
  Scan scan = new Scan(get);
  InternalScanner scanner = (InternalScanner) store.getScanner(scan,
      scan.getFamilyMap().get(store.getFamily().getName()));

  List<KeyValue> result = new ArrayList<KeyValue>();
  scanner.next(result);
  if (!result.isEmpty()) {
    // verify that we are on the row we want:
    KeyValue kv = result.get(0);
    if (!Bytes.equals(kv.getRow(), get.getRow())) {
      result.clear();
    }
  }
  scanner.close();
  return result;
}
 

import org.apache.hadoop.hbase.regionserver.MultiVersionConsistencyControl; //导入依赖的package包/类
@Override
public void process() {
  try {
    MultiVersionConsistencyControl.setThreadReadPoint(readPoint);
    scanner.seek(keyValue);
  } catch (IOException e) {
    LOG.error("", e);
    setErr(e);
  } finally {
    latch.countDown();
  }
}
 

import org.apache.hadoop.hbase.regionserver.MultiVersionConsistencyControl; //导入依赖的package包/类
protected long setSmallestReadPoint() {
  long smallestReadPoint = store.getSmallestReadPoint();
  MultiVersionConsistencyControl.setThreadReadPoint(smallestReadPoint);
  return smallestReadPoint;
}