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

HStore.closeAndArchiveCompactedFiles介绍

[英]Closes and archives the compacted files under this store
[中]关闭并归档此存储下的压缩文件

代码示例

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

@Override
 public void process() throws IOException {
  this.store.closeAndArchiveCompactedFiles();
 }
}

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

/**
 * Closes and archives the compacted files under this store
 */
public synchronized void closeAndArchiveCompactedFiles() throws IOException {
 closeAndArchiveCompactedFiles(false);
}

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

store.closeAndArchiveCompactedFiles();

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

public static void removeCompactedFiles(Connection conn, long timeout, RegionInfo hri)
  throws IOException, InterruptedException {
 log("remove compacted files for : " + hri.getRegionNameAsString());
 List<HRegion> regions = TEST_UTIL.getHBaseCluster().getRegions(hri.getTable());
 regions.stream().forEach(r -> {
  try {
   r.getStores().get(0).closeAndArchiveCompactedFiles();
  } catch (IOException ioe) {
   LOG.error("failed in removing compacted file", ioe);
  }
 });
}

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

@Override
 public void doAnAction() throws Exception {
  region.flush(true);
  // Compact regularly to avoid creating too many files and exceeding
  // the ulimit.
  region.compact(false);
  for (HStore store : region.getStores()) {
   store.closeAndArchiveCompactedFiles();
  }
 }
});

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

retrier.sleepUntilNextRetry();
region.getStores().get(0).closeAndArchiveCompactedFiles();

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

s.closeAndArchiveCompactedFiles();
} catch (IOException e1) {
 LOG.error("Error whiling cleaning compacted file");

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

region.compact(true);
for (HStore store : region.getStores()) {
 store.closeAndArchiveCompactedFiles();

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

assertNotNull(preadScanner.next());
assertNotNull(streamScanner.next());
store.closeAndArchiveCompactedFiles(true);

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

daughterRegion = r;
r.getStores().get(0).closeAndArchiveCompactedFiles();
LOG.info("Found matching HRI: " + daughterRegion);
break;

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

store.closeAndArchiveCompactedFiles();

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

store.triggerMajorCompaction();
region.compact(true);
store.closeAndArchiveCompactedFiles();
waitForStoreFileCount(store, 1, 10000); // wait 10 seconds max
assertEquals(1, store.getStorefilesCount());

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

retrier.sleepUntilNextRetry();
daughter.getStores().get(0).closeAndArchiveCompactedFiles();
assertFalse(daughter.hasReferences());

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

public static void removeCompactedFiles(Connection conn, long timeout, RegionInfo hri)
  throws IOException, InterruptedException {
 log("remove compacted files for : " + hri.getRegionNameAsString());
 List<HRegion> regions = TEST_UTIL.getHBaseCluster().getRegions(hri.getTable());
 regions.stream().forEach(r -> {
  try {
   r.getStores().get(0).closeAndArchiveCompactedFiles();
  } catch (IOException ioe) {
   LOG.error("failed in removing compacted file", ioe);
  }
 });
}

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

@Override
 public void doAnAction() throws Exception {
  region.flush(true);
  // Compact regularly to avoid creating too many files and exceeding
  // the ulimit.
  region.compact(false);
  for (HStore store : region.getStores()) {
   store.closeAndArchiveCompactedFiles();
  }
 }
});

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

retrier.sleepUntilNextRetry();
region.getStores().get(0).closeAndArchiveCompactedFiles();

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

region.compact(true);
for (HStore store : region.getStores()) {
 store.closeAndArchiveCompactedFiles();

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

assertNotNull(preadScanner.next());
assertNotNull(streamScanner.next());
store.closeAndArchiveCompactedFiles(true);

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

store.closeAndArchiveCompactedFiles();

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

retrier.sleepUntilNextRetry();
daughter.getStores().get(0).closeAndArchiveCompactedFiles();
assertFalse(daughter.hasReferences());