本文整理了Java中org.apache.hadoop.hbase.regionserver.Region.getStoreFileList
方法的一些代码示例,展示了Region.getStoreFileList
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Region.getStoreFileList
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.regionserver.Region
类名称: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());
内容来源于网络,如有侵权,请联系作者删除!