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

x33g5p2x  于2022-01-30 转载在 其他  
字(1.4k)|赞(0)|评价(0)|浏览(143)

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

Store.compact介绍

暂无

代码示例

代码示例来源:origin: co.cask.hbase/hbase

/**
 * Execute the actual compaction job.
 * If the compact once flag is not specified, execute the compaction until
 * no more compactions are needed. Uses the Configuration settings provided.
 */
private void compactStoreFiles(final HRegion region, final Path familyDir,
  final boolean compactOnce) throws IOException {
 LOG.info("Compact table=" + region.getTableDesc().getNameAsString() +
  " region=" + region.getRegionNameAsString() +
  " family=" + familyDir.getName());
 Store store = getStore(region, familyDir);
 do {
  CompactionRequest cr = store.requestCompaction();
  StoreFile storeFile = store.compact(cr);
  if (storeFile != null) {
   if (keepCompactedFiles && deleteCompacted) {
    fs.delete(storeFile.getPath(), false);
   }
  }
 } while (store.needsCompaction() && !compactOnce);
}

代码示例来源:origin: co.cask.hbase/hbase

try {
 status.setStatus("Compacting store " + cr.getStore());
 cr.getStore().compact(cr);
} catch (InterruptedIOException iioe) {
 String msg = "compaction interrupted by user";

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

store.compact(compaction, throughputController, user);
} catch (InterruptedIOException iioe) {
 String msg = "compaction interrupted";

相关文章