Java 类org.apache.hadoop.hbase.regionserver.MultiVersionConsistencyControl 实例源码

项目:LCIndex-HBase-0.94.16    文件:HBaseTestingUtility.java   
/**
 * 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;
}
项目:IRIndex    文件:HBaseTestingUtility.java   
/**
 * 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;
}
项目:c5    文件:HBaseTestingUtility.java   
/**
 * 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;
}
项目:HBase-Research    文件:HBaseTestingUtility.java   
/**
 * 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;
}
项目:hbase-0.94.8-qod    文件:HBaseTestingUtility.java   
/**
 * 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;
}
项目:hbase-0.94.8-qod    文件:HBaseTestingUtility.java   
/**
 * 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;
}
项目:DominoHBase    文件:HBaseTestingUtility.java   
/**
 * 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;
}
项目:hindex    文件:HBaseTestingUtility.java   
/**
 * 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;
}
项目:c5    文件:ParallelSeekHandler.java   
@Override
public void process() {
  try {
    MultiVersionConsistencyControl.setThreadReadPoint(readPoint);
    scanner.seek(keyValue);
  } catch (IOException e) {
    LOG.error("", e);
    setErr(e);
  } finally {
    latch.countDown();
  }
}
项目:c5    文件:Compactor.java   
protected long setSmallestReadPoint() {
  long smallestReadPoint = store.getSmallestReadPoint();
  MultiVersionConsistencyControl.setThreadReadPoint(smallestReadPoint);
  return smallestReadPoint;
}