本文整理了Java中org.apache.hadoop.hbase.regionserver.Region.getScanner方法的一些代码示例，展示了Region.getScanner的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台，是从一些精选项目中提取出来的代码，具有较强的参考意义，能在一定程度帮忙到你。Region.getScanner方法的具体详情如下：
包路径：org.apache.hadoop.hbase.regionserver.Region
类名称：Region
方法名：getScanner

Region.getScanner介绍

[英]Return an iterator that scans over the HRegion, returning the indicated columns and rows specified by the Scan.

This Iterator must be closed by the caller.
[中]返回一个遍历HRegion的迭代器，返回扫描指定的列和行。
调用方必须关闭此迭代器。

代码示例

代码示例来源：origin: apache/hbase

protected List<List<Cell>> getExistingLabelsWithAuths() throws IOException {
 Scan scan = new Scan();
 RegionScanner scanner = labelsRegion.getScanner(scan);
 List<List<Cell>> existingLabels = new ArrayList<>();
 try {
  while (true) {
   List<Cell> cells = new ArrayList<>();
   scanner.next(cells);
   if (cells.isEmpty()) {
    break;
   }
   existingLabels.add(cells);
  }
 } finally {
  scanner.close();
 }
 return existingLabels;
}

代码示例来源：origin: apache/hbase

@Override
public ResultScanner getScanner(Scan scan) throws IOException {
 return new RegionScannerToResultScannerAdaptor(this.region.getScanner(scan));
}

代码示例来源：origin: apache/hbase

private void scanAllRegionsForRS(HRegionServer rs) throws IOException {
 for (Region region : rs.getRegions(TABLE_NAME)) {
  RegionScanner scanner = region.getScanner(new Scan());
  while (scanner.next(new ArrayList<Cell>()));
 }
}

代码示例来源：origin: apache/hbase

s.setFilter(filter);
ArrayList<String> auths = new ArrayList<>();
RegionScanner scanner = this.labelsRegion.getScanner(s);
try {
 List<Cell> results = new ArrayList<>(1);

代码示例来源：origin: apache/hbase

s.setFilter(filter);
Set<String> auths = new HashSet<>();
RegionScanner scanner = this.labelsRegion.getScanner(s);
try {
 List<Cell> results = new ArrayList<>(1);

代码示例来源：origin: apache/hbase

public int countRows(final Region region, final Scan scan) throws IOException {
 InternalScanner scanner = region.getScanner(scan);
 try {
  return countRows(scanner);
 } finally {
  scanner.close();
 }
}

代码示例来源：origin: apache/hbase

@Override
public void postOpen(ObserverContext<RegionCoprocessorEnvironment> c) {
 RegionCoprocessorEnvironment env = c.getEnvironment();
 Region region = env.getRegion();
 try {
  putData(region);
  RegionScanner scanner = region.getScanner(new Scan());
  List<Cell> result = new LinkedList<>();
  while (scanner.next(result)) {
   result.clear();
  }
 } catch (Exception e) {
  LOG.warn("Got exception in coprocessor", e);
 }
}

代码示例来源：origin: apache/hbase

InternalScanner scanner = null;
try {
 scanner = env.getRegion().getScanner(new Scan());
 List<Cell> results = new ArrayList<>();
 boolean hasMore = false;

代码示例来源：origin: apache/hbase

iScanner = aclRegion.getScanner(scan);

代码示例来源：origin: apache/hbase

});
List<Cell> cells = new ArrayList<>();
try (RegionScanner scanner = c.getEnvironment().getRegion().getScanner(scan)) {
 boolean moreRows;
 do {

代码示例来源：origin: apache/hbase

scan.setFilter(new FirstKeyOnlyFilter());
scanner = env.getRegion().getScanner(scan);
boolean hasMoreRows = false;
do {

代码示例来源：origin: apache/hbase

InternalScanner scanner = null;
try {
 scanner = env.getRegion().getScanner(scan);
 List<Cell> results = new ArrayList<>();
 boolean hasMore = false;

代码示例来源：origin: apache/hbase

public Result getClosestRowBefore(Region r, byte[] row, byte[] family) throws IOException {
 Scan scan = new Scan(row);
 scan.setSmall(true);
 scan.setCaching(1);
 scan.setReversed(true);
 scan.addFamily(family);
 try (RegionScanner scanner = r.getScanner(scan)) {
  List<Cell> cells = new ArrayList<>(1);
  scanner.next(cells);
  if (r.getRegionInfo().isMetaRegion() && !isTargetTable(row, cells.get(0))) {
   return null;
  }
  return Result.create(cells);
 }
}

代码示例来源：origin: apache/hbase

T temp;
Scan scan = ProtobufUtil.toScan(request.getScan());
scanner = env.getRegion().getScanner(scan);
List<Cell> results = new ArrayList<>();
byte[] colFamily = scan.getFamilies()[0];

代码示例来源：origin: apache/hbase

T temp;
Scan scan = ProtobufUtil.toScan(request.getScan());
scanner = env.getRegion().getScanner(scan);
List<Cell> results = new ArrayList<>();
byte[] colFamily = scan.getFamilies()[0];

代码示例来源：origin: apache/hbase

T temp;
Scan scan = ProtobufUtil.toScan(request.getScan());
scanner = env.getRegion().getScanner(scan);
byte[] colFamily = scan.getFamilies()[0];
NavigableSet<byte[]> qualifiers = scan.getFamilyMap().get(colFamily);

代码示例来源：origin: apache/hbase

InternalScanner scanner = region.getScanner(s);
List<Cell> kvs = new ArrayList<>();
scanner.next(kvs);
scanner = region.getScanner(s);
kvs = new ArrayList<>();
scanner.next(kvs);

代码示例来源：origin: apache/hbase

/**
 * The ExplicitColumnTracker does not support "raw" scanning.
 */
@Test
public void testRawScanWithColumns() throws Exception {
 HTableDescriptor htd = hbu.createTableDescriptor(name.getMethodName(), 0, 3,
   HConstants.FOREVER, KeepDeletedCells.TRUE);
 Region region = hbu.createLocalHRegion(htd, null, null);
 Scan s = new Scan();
 s.setRaw(true);
 s.setMaxVersions();
 s.addColumn(c0, c0);
 try {
  region.getScanner(s);
  fail("raw scanner with columns should have failed");
 } catch (org.apache.hadoop.hbase.DoNotRetryIOException dnre) {
  // ok!
 }
 HBaseTestingUtility.closeRegionAndWAL(region);
}

代码示例来源：origin: apache/hbase

InternalScanner scanner = null;
try {
 scanner = this.env.getRegion().getScanner(scan);
 List<Cell> curVals = new ArrayList<>();
 boolean hasMore = false;

代码示例来源：origin: apache/hbase

throw new DoNotRetryIOException("An expected exception");
scanner = region.getScanner(scan);
List<Cell> curVals = new ArrayList<>();
boolean hasMore = false;