org.apache.hadoop.hbase.MetaTableAccessor.fullScan()方法的使用及代码示例

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

MetaTableAccessor.fullScan介绍

[英]Performs a full scan of hbase:meta.
[中]对hbase:meta执行完整扫描。

代码示例

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

/**
* Performs a full scan of hbase:meta for regions.
* @param connection connection we're using
*/
public static List fullScanRegions(Connection connection)
throws IOException {
return fullScan(connection, QueryType.REGION);
}

代码示例来源：origin: org.apache.hbase/hbase-client

/**
* Performs a full scan of hbase:meta for regions.
* @param connection connection we're using
*/
public static List fullScanRegions(Connection connection)
throws IOException {
return fullScan(connection, QueryType.REGION);
}

代码示例来源：origin: com.aliyun.hbase/alihbase-client

/**
* Performs a full scan of hbase:meta for regions.
* @param connection connection we're using
*/
public static List fullScanRegions(Connection connection)
throws IOException {
return fullScan(connection, QueryType.REGION);
}

代码示例来源：origin: harbby/presto-connectors

/**
* Performs a full scan of hbase:meta.
* @param connection connection we're using
* @param visitor Visitor invoked against each row.
* @throws IOException
*/
public static void fullScan(Connection connection,
final Visitor visitor)
throws IOException {
fullScan(connection, visitor, null);
}

代码示例来源：origin: harbby/presto-connectors

public static void fullScanMetaAndPrint(Connection connection)
throws IOException {
Visitor v = new Visitor() {
@Override
public boolean visit(Result r) throws IOException {
if (r == null || r.isEmpty()) return true;
LOG.info("fullScanMetaAndPrint.Current Meta Row: " + r);
RegionLocations locatiOns= getRegionLocations(r);
if (locatiOns== null) return true;
for (HRegionLocation loc : locations.getRegionLocations()) {
if (loc != null) {
LOG.info("fullScanMetaAndPrint.HRI Print= " + loc.getRegionInfo());
}
}
return true;
}
};
fullScan(connection, v);
}

代码示例来源：origin: harbby/presto-connectors

fullScan(connection, v);
return hris;

代码示例来源：origin: harbby/presto-connectors

/**
* Performs a full scan of hbase:meta.
* @param connection connection we're using
* @return List of {@link Result}
* @throws IOException
*/
public static List fullScan(Connection connection)
throws IOException {
CollectAllVisitor v = new CollectAllVisitor();
fullScan(connection, v, null);
return v.getResults();
}

代码示例来源：origin: harbby/presto-connectors

/**
* Performs a full scan of a hbase:meta table.
* @return List of {@link org.apache.hadoop.hbase.client.Result}
* @throws IOException
*/
public static List fullScanOfMeta(Connection connection)
throws IOException {
CollectAllVisitor v = new CollectAllVisitor();
fullScan(connection, v, null);
return v.getResults();
}

代码示例来源：origin: harbby/presto-connectors

/**
* Update hbase:meta rows, converting writable serialization to PB
* @return num migrated rows
*/
static long updateMeta(final MasterServices masterServices) throws IOException {
LOG.info("Starting update of META");
ConvertToPBMetaVisitor v = new ConvertToPBMetaVisitor(masterServices);
MetaTableAccessor.fullScan(masterServices.getConnection(), v);
LOG.info("Finished update of META. Total rows updated:" + v.numMigratedRows);
return v.numMigratedRows;
}

代码示例来源：origin: harbby/presto-connectors

fullScan(connection, visitor, getTableStartRowForMeta(tableName));

代码示例来源：origin: harbby/presto-connectors

MetaTableAccessor.fullScan(connection, v);

代码示例来源：origin: harbby/presto-connectors

fullScan(connection, visitor, getTableStartRowForMeta(tableName));
return visitor.getResults();