org.apache.hadoop.hbase.regionserver.KeyValueScanner#peek ( )源码实例Demo

下面列出了org.apache.hadoop.hbase.regionserver.KeyValueScanner#peek ( ) 实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

源代码1 项目: phoenix   文件: LocalTableState.java
public Result getCurrentRowState() {
  KeyValueScanner scanner = this.memstore.getScanner();
  List<Cell> kvs = new ArrayList<Cell>();
  while (scanner.peek() != null) {
    try {
      kvs.add(scanner.next());
    } catch (IOException e) {
      // this should never happen - something has gone terribly arwy if it has
      throw new RuntimeException("Local MemStore threw IOException!");
    }
  }
  return Result.create(kvs);
}
 
源代码2 项目: phoenix   文件: LocalTableState.java
public Result getCurrentRowState() {
  KeyValueScanner scanner = this.memstore.getScanner();
  List<KeyValue> kvs = new ArrayList<KeyValue>();
  while (scanner.peek() != null) {
    try {
      kvs.add(scanner.next());
    } catch (IOException e) {
      // this should never happen - something has gone terribly arwy if it has
      throw new RuntimeException("Local MemStore threw IOException!");
    }
  }
  return new Result(kvs);
}