org.apache.hadoop.hbase.regionserver.Region.getStoreFileList()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(2.8k)|赞(0)|评价(0)|浏览(65)

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

Region.getStoreFileList介绍

暂无

代码示例

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

private static int countStoreFilesInFamilies(List<Region> regions, final byte[][] families) {
 int count = 0;
 for (Region region : regions) {
  count += region.getStoreFileList(families).size();
 }
 return count;
}

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

assertEquals(refSFCount, region.getStoreFileList(new byte[][]{familyNameBytes}).size());
assertEquals(1, region.getStoreFileList(new byte[][]{familyNameBytes}).size());
assertEquals(refSFCount+1,
 ((HStore)region.getStore(familyNameBytes)).getStoreEngine().getStoreFileManager()
assertEquals(1, region.getStoreFileList(new byte[][]{familyNameBytes}).size());
assertEquals(0,
  ((HStore)region.getStore(familyNameBytes)).getStoreEngine().getStoreFileManager()

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

assertEquals(refSFCount, region.getStoreFileList(new byte[][]{familyNameBytes}).size());

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

private static int countStoreFilesInFamilies(List<Region> regions, final byte[][] families) {
 int count = 0;
 for (Region region : regions) {
  count += region.getStoreFileList(families).size();
 }
 return count;
}

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

@Override
@QosPriority(priority=HConstants.ADMIN_QOS)
public GetStoreFileResponse getStoreFile(final RpcController controller,
  final GetStoreFileRequest request) throws ServiceException {
 try {
  checkOpen();
  Region region = getRegion(request.getRegion());
  requestCount.increment();
  Set<byte[]> columnFamilies;
  if (request.getFamilyCount() == 0) {
   columnFamilies = region.getTableDesc().getFamiliesKeys();
  } else {
   columnFamilies = new TreeSet<byte[]>(Bytes.BYTES_RAWCOMPARATOR);
   for (ByteString cf: request.getFamilyList()) {
    columnFamilies.add(cf.toByteArray());
   }
  }
  int nCF = columnFamilies.size();
  List<String>  fileList = region.getStoreFileList(
   columnFamilies.toArray(new byte[nCF][]));
  GetStoreFileResponse.Builder builder = GetStoreFileResponse.newBuilder();
  builder.addAllStoreFile(fileList);
  return builder.build();
 } catch (IOException ie) {
  throw new ServiceException(ie);
 }
}

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

assertEquals(refSFCount, region.getStoreFileList(new byte[][]{familyNameBytes}).size());
assertEquals(1, region.getStoreFileList(new byte[][]{familyNameBytes}).size());
assertEquals(refSFCount+1,
 ((HStore)region.getStore(familyNameBytes)).getStoreEngine().getStoreFileManager()
assertEquals(1, region.getStoreFileList(new byte[][]{familyNameBytes}).size());
assertEquals(0,
  ((HStore)region.getStore(familyNameBytes)).getStoreEngine().getStoreFileManager()

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

assertEquals(refSFCount, region.getStoreFileList(new byte[][]{familyNameBytes}).size());

相关文章