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

HStore.replaceStoreFiles介绍

暂无

代码示例

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

replaceStoreFiles(toBeRemovedStoreFiles, openedFiles); //won't throw an exception

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

LOG.info("Replaying compaction marker, replacing input files: " +
  inputStoreFiles + " with output files : " + outputStoreFiles);
this.replaceStoreFiles(inputStoreFiles, outputStoreFiles);
this.completeCompaction(inputStoreFiles);

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

this.getCoprocessorHost().postCompact(this, sf, null, null, null);
replaceStoreFiles(filesToCompact, Collections.singletonList(sf));
completeCompaction(filesToCompact);

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

replaceStoreFiles(delSfs, newFiles);
completeCompaction(delSfs);
LOG.info("Completed removal of " + delSfs.size() + " unnecessary (expired) file(s) in "

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

@Test
public void testRefreshStoreFilesNotChanged() throws IOException {
 init(name.getMethodName());
 assertEquals(0, this.store.getStorefilesCount());
 // add some data, flush
 this.store.add(new KeyValue(row, family, qf1, 1, (byte[])null), null);
 flush(1);
 // add one more file
 addStoreFile();
 HStore spiedStore = spy(store);
 // call first time after files changed
 spiedStore.refreshStoreFiles();
 assertEquals(2, this.store.getStorefilesCount());
 verify(spiedStore, times(1)).replaceStoreFiles(any(), any());
 // call second time
 spiedStore.refreshStoreFiles();
 //ensure that replaceStoreFiles is not called if files are not refreshed
 verify(spiedStore, times(0)).replaceStoreFiles(null, null);
}

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

@VisibleForTesting
protected List<HStoreFile> doCompaction(CompactionRequestImpl cr,
  Collection<HStoreFile> filesToCompact, User user, long compactionStartTime,
  List<Path> newFiles) throws IOException {
 // Do the steps necessary to complete the compaction.
 List<HStoreFile> sfs = moveCompactedFilesIntoPlace(cr, newFiles, user);
 writeCompactionWalRecord(filesToCompact, sfs);
 replaceStoreFiles(filesToCompact, sfs);
 if (cr.isMajor()) {
  majorCompactedCellsCount.addAndGet(getCompactionProgress().getTotalCompactingKVs());
  majorCompactedCellsSize.addAndGet(getCompactionProgress().totalCompactedSize);
 } else {
  compactedCellsCount.addAndGet(getCompactionProgress().getTotalCompactingKVs());
  compactedCellsSize.addAndGet(getCompactionProgress().totalCompactedSize);
 }
 long outputBytes = getTotalSize(sfs);
 // At this point the store will use new files for all new scanners.
 completeCompaction(filesToCompact); // update store size.
 long now = EnvironmentEdgeManager.currentTime();
 if (region.getRegionServerServices() != null
   && region.getRegionServerServices().getMetrics() != null) {
  region.getRegionServerServices().getMetrics().updateCompaction(
    region.getTableDescriptor().getTableName().getNameAsString(),
    cr.isMajor(), now - compactionStartTime, cr.getFiles().size(),
    newFiles.size(), cr.getSize(), outputBytes);
 }
 logCompactionEndMessage(cr, sfs, now, compactionStartTime);
 return sfs;
}

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

this.getCoprocessorHost().postCompact(this, sf, null);
replaceStoreFiles(filesToCompact, Lists.newArrayList(sf));
completeCompaction(filesToCompact, true);

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

replaceStoreFiles(toBeRemovedStoreFiles, openedFiles); //won't throw an exception

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

LOG.info("Replaying compaction marker, replacing input files: " +
  inputStoreFiles + " with output files : " + outputStoreFiles);
this.replaceStoreFiles(inputStoreFiles, outputStoreFiles);
this.completeCompaction(inputStoreFiles, removeFiles);

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

private void removeUnneededFiles() throws IOException {
 if (!conf.getBoolean("hbase.store.delete.expired.storefile", true)) return;
 if (getFamily().getMinVersions() > 0) {
  LOG.debug("Skipping expired store file removal due to min version being " +
    getFamily().getMinVersions());
  return;
 }
 this.lock.readLock().lock();
 Collection<StoreFile> delSfs = null;
 try {
  synchronized (filesCompacting) {
   long cfTtl = getStoreFileTtl();
   if (cfTtl != Long.MAX_VALUE) {
    delSfs = storeEngine.getStoreFileManager().getUnneededFiles(
      EnvironmentEdgeManager.currentTime() - cfTtl, filesCompacting);
    addToCompactingFiles(delSfs);
   }
  }
 } finally {
  this.lock.readLock().unlock();
 }
 if (delSfs == null || delSfs.isEmpty()) return;
 Collection<StoreFile> newFiles = new ArrayList<StoreFile>(); // No new files.
 writeCompactionWalRecord(delSfs, newFiles);
 replaceStoreFiles(delSfs, newFiles);
 completeCompaction(delSfs);
 LOG.info("Completed removal of " + delSfs.size() + " unnecessary (expired) file(s) in "
   + this + " of " + this.getRegionInfo().getRegionNameAsString()
   + "; total size for store is " + TraditionalBinaryPrefix.long2String(storeSize, "", 1));
}

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

@Test
public void testRefreshStoreFilesNotChanged() throws IOException {
 init(name.getMethodName());
 assertEquals(0, this.store.getStorefilesCount());
 // add some data, flush
 this.store.add(new KeyValue(row, family, qf1, 1, (byte[])null), null);
 flush(1);
 // add one more file
 addStoreFile();
 HStore spiedStore = spy(store);
 // call first time after files changed
 spiedStore.refreshStoreFiles();
 assertEquals(2, this.store.getStorefilesCount());
 verify(spiedStore, times(1)).replaceStoreFiles(any(), any());
 // call second time
 spiedStore.refreshStoreFiles();
 //ensure that replaceStoreFiles is not called if files are not refreshed
 verify(spiedStore, times(0)).replaceStoreFiles(null, null);
}

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

replaceStoreFiles(filesToCompact, sfs);
if (cr.isMajor()) {
 majorCompactedCellsCount += getCompactionProgress().totalCompactingKVs;