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

HStore.getCompactionProgress介绍

[英]getter for CompactionProgress object
[中]CompactionProgress对象的getter

代码示例

代码示例来源：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: apache/hbase

assertNull(store.getCompactionProgress());
CompactionProgress progress = store.getCompactionProgress();
if( progress != null ) {
 ++storeCount;

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

CompactionProgress progress = store.getCompactionProgress();
if (progress != null) {
 totalCompactingKVs += progress.getTotalCompactingKVs();

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

replaceStoreFiles(filesToCompact, sfs);
if (cr.isMajor()) {
 majorCompactedCellsCount += getCompactionProgress().totalCompactingKVs;
 majorCompactedCellsSize += getCompactionProgress().totalCompactedSize;
} else {
 compactedCellsCount += getCompactionProgress().totalCompactingKVs;
 compactedCellsSize += getCompactionProgress().totalCompactedSize;

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

assertNull(store.getCompactionProgress());
CompactionProgress progress = store.getCompactionProgress();
if( progress != null ) {
 ++storeCount;