Java 类org.apache.hadoop.hbase.regionserver.compactions.CompactionProgress 实例源码

项目：LCIndex-HBase-0.94.16 文件：HRegionServer.java

private HServerLoad.RegionLoad createRegionLoad(final HRegion r) {
  byte[] name = r.getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  synchronized (r.stores) {
    stores += r.stores.size();
    for (Store store : r.stores.values()) {
      storefiles += store.getStorefilesCount();
      storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed() / 1024 / 1024);
      storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
      storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
      CompactionProgress progress = store.getCompactionProgress();
      if (progress != null) {
        totalCompactingKVs += progress.totalCompactingKVs;
        currentCompactedKVs += progress.currentCompactedKVs;
      }

      rootIndexSizeKB += (int) (store.getStorefilesIndexSize() / 1024);

      totalStaticIndexSizeKB += (int) (store.getTotalStaticIndexSize() / 1024);

      totalStaticBloomSizeKB += (int) (store.getTotalStaticBloomSize() / 1024);
    }
  }
  return new HServerLoad.RegionLoad(name, stores, storefiles, storeUncompressedSizeMB,
      storefileSizeMB, memstoreSizeMB, storefileIndexSizeMB, rootIndexSizeKB,
      totalStaticIndexSizeKB, totalStaticBloomSizeKB, (int) r.readRequestsCount.get(),
      (int) r.writeRequestsCount.get(), totalCompactingKVs, currentCompactedKVs);
}

项目：ditb 文件：HRegionServer.java

private RegionLoad createRegionLoad(final Region r, RegionLoad.Builder regionLoadBldr,
    RegionSpecifier.Builder regionSpecifier) throws IOException {
  byte[] name = r.getRegionInfo().getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.getMemstoreSize() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  List<Store> storeList = r.getStores();
  stores += storeList.size();
  for (Store store : storeList) {
    storefiles += store.getStorefilesCount();
    storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed() / 1024 / 1024);
    storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
    storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
    CompactionProgress progress = store.getCompactionProgress();
    if (progress != null) {
      totalCompactingKVs += progress.totalCompactingKVs;
      currentCompactedKVs += progress.currentCompactedKVs;
    }
    rootIndexSizeKB += (int) (store.getStorefilesIndexSize() / 1024);
    totalStaticIndexSizeKB += (int) (store.getTotalStaticIndexSize() / 1024);
    totalStaticBloomSizeKB += (int) (store.getTotalStaticBloomSize() / 1024);
  }

  float dataLocality =
      r.getHDFSBlocksDistribution().getBlockLocalityIndex(serverName.getHostname());
  if (regionLoadBldr == null) {
    regionLoadBldr = RegionLoad.newBuilder();
  }
  if (regionSpecifier == null) {
    regionSpecifier = RegionSpecifier.newBuilder();
  }
  regionSpecifier.setType(RegionSpecifierType.REGION_NAME);
  regionSpecifier.setValue(ByteStringer.wrap(name));
  regionLoadBldr.setRegionSpecifier(regionSpecifier.build()).setStores(stores)
      .setStorefiles(storefiles).setStoreUncompressedSizeMB(storeUncompressedSizeMB)
      .setStorefileSizeMB(storefileSizeMB).setMemstoreSizeMB(memstoreSizeMB)
      .setStorefileIndexSizeMB(storefileIndexSizeMB).setRootIndexSizeKB(rootIndexSizeKB)
      .setTotalStaticIndexSizeKB(totalStaticIndexSizeKB)
      .setTotalStaticBloomSizeKB(totalStaticBloomSizeKB)
      .setReadRequestsCount(r.getReadRequestsCount())
      .setWriteRequestsCount(r.getWriteRequestsCount()).setTotalCompactingKVs(totalCompactingKVs)
      .setCurrentCompactedKVs(currentCompactedKVs).setDataLocality(dataLocality)
      .setLastMajorCompactionTs(r.getOldestHfileTs(true));
  ((HRegion) r).setCompleteSequenceId(regionLoadBldr);

  return regionLoadBldr.build();
}

项目：ditb 文件：HStore.java

@Override public CompactionProgress getCompactionProgress() {
  return this.storeEngine.getCompactor().getProgress();
}

项目：LCIndex-HBase-0.94.16 文件：Compactor.java

CompactionProgress getProgress() {
  return this.progress;
}

项目：pbase 文件：HRegionServer.java

private RegionLoad createRegionLoad(final HRegion r, RegionLoad.Builder regionLoadBldr,
                                    RegionSpecifier.Builder regionSpecifier) {
    byte[] name = r.getRegionName();
    int stores = 0;
    int storefiles = 0;
    int storeUncompressedSizeMB = 0;
    int storefileSizeMB = 0;
    int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
    int storefileIndexSizeMB = 0;
    int rootIndexSizeKB = 0;
    int totalStaticIndexSizeKB = 0;
    int totalStaticBloomSizeKB = 0;
    long totalCompactingKVs = 0;
    long currentCompactedKVs = 0;
    synchronized (r.stores) {
        stores += r.stores.size();
        for (Store store : r.stores.values()) {
            storefiles += store.getStorefilesCount();
            storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
                    / 1024 / 1024);
            storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
            storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
            CompactionProgress progress = store.getCompactionProgress();
            if (progress != null) {
                totalCompactingKVs += progress.totalCompactingKVs;
                currentCompactedKVs += progress.currentCompactedKVs;
            }

            rootIndexSizeKB +=
                    (int) (store.getStorefilesIndexSize() / 1024);

            totalStaticIndexSizeKB +=
                    (int) (store.getTotalStaticIndexSize() / 1024);

            totalStaticBloomSizeKB +=
                    (int) (store.getTotalStaticBloomSize() / 1024);
        }
    }
    float dataLocality =
            r.getHDFSBlocksDistribution().getBlockLocalityIndex(serverName.getHostname());
    if (regionLoadBldr == null) {
        regionLoadBldr = RegionLoad.newBuilder();
    }
    if (regionSpecifier == null) {
        regionSpecifier = RegionSpecifier.newBuilder();
    }
    regionSpecifier.setType(RegionSpecifierType.REGION_NAME);
    regionSpecifier.setValue(ByteStringer.wrap(name));
    regionLoadBldr.setRegionSpecifier(regionSpecifier.build())
            .setStores(stores)
            .setStorefiles(storefiles)
            .setStoreUncompressedSizeMB(storeUncompressedSizeMB)
            .setStorefileSizeMB(storefileSizeMB)
            .setMemstoreSizeMB(memstoreSizeMB)
            .setStorefileIndexSizeMB(storefileIndexSizeMB)
            .setRootIndexSizeKB(rootIndexSizeKB)
            .setTotalStaticIndexSizeKB(totalStaticIndexSizeKB)
            .setTotalStaticBloomSizeKB(totalStaticBloomSizeKB)
            .setReadRequestsCount(r.readRequestsCount.get())
            .setWriteRequestsCount(r.writeRequestsCount.get())
            .setTotalCompactingKVs(totalCompactingKVs)
            .setCurrentCompactedKVs(currentCompactedKVs)
            .setCompleteSequenceId(r.lastFlushSeqId)
            .setDataLocality(dataLocality);

    return regionLoadBldr.build();
}

项目：pbase 文件：HStore.java

@Override
public CompactionProgress getCompactionProgress() {
    return this.storeEngine.getCompactor().getProgress();
}

项目：HIndex 文件：HRegionServer.java

private RegionLoad createRegionLoad(final HRegion r, RegionLoad.Builder regionLoadBldr,
    RegionSpecifier.Builder regionSpecifier) {
  byte[] name = r.getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  synchronized (r.stores) {
    stores += r.stores.size();
    for (Store store : r.stores.values()) {
      storefiles += store.getStorefilesCount();
      storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
          / 1024 / 1024);
      storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
      storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
      CompactionProgress progress = store.getCompactionProgress();
      if (progress != null) {
        totalCompactingKVs += progress.totalCompactingKVs;
        currentCompactedKVs += progress.currentCompactedKVs;
      }

      rootIndexSizeKB +=
          (int) (store.getStorefilesIndexSize() / 1024);

      totalStaticIndexSizeKB +=
        (int) (store.getTotalStaticIndexSize() / 1024);

      totalStaticBloomSizeKB +=
        (int) (store.getTotalStaticBloomSize() / 1024);
    }
  }
  if (regionLoadBldr == null) {
    regionLoadBldr = RegionLoad.newBuilder();
  }
  if (regionSpecifier == null) {
    regionSpecifier = RegionSpecifier.newBuilder();
  }
  regionSpecifier.setType(RegionSpecifierType.REGION_NAME);
  regionSpecifier.setValue(HBaseZeroCopyByteString.wrap(name));
  regionLoadBldr.setRegionSpecifier(regionSpecifier.build())
    .setStores(stores)
    .setStorefiles(storefiles)
    .setStoreUncompressedSizeMB(storeUncompressedSizeMB)
    .setStorefileSizeMB(storefileSizeMB)
    .setMemstoreSizeMB(memstoreSizeMB)
    .setStorefileIndexSizeMB(storefileIndexSizeMB)
    .setRootIndexSizeKB(rootIndexSizeKB)
    .setTotalStaticIndexSizeKB(totalStaticIndexSizeKB)
    .setTotalStaticBloomSizeKB(totalStaticBloomSizeKB)
    .setReadRequestsCount(r.readRequestsCount.get())
    .setWriteRequestsCount(r.writeRequestsCount.get())
    .setTotalCompactingKVs(totalCompactingKVs)
    .setCurrentCompactedKVs(currentCompactedKVs)
    .setCompleteSequenceId(r.completeSequenceId);

  return regionLoadBldr.build();
}

项目：HIndex 文件：HStore.java

@Override
public CompactionProgress getCompactionProgress() {
  return this.storeEngine.getCompactor().getProgress();
}

项目：IRIndex 文件：HRegionServer.java

private HServerLoad.RegionLoad createRegionLoad(final HRegion r) {
  byte[] name = r.getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  synchronized (r.stores) {
    stores += r.stores.size();
    for (Store store : r.stores.values()) {
      storefiles += store.getStorefilesCount();
      storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
          / 1024 / 1024);
      storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
      storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
      CompactionProgress progress = store.getCompactionProgress();
      if (progress != null) {
        totalCompactingKVs += progress.totalCompactingKVs;
        currentCompactedKVs += progress.currentCompactedKVs;
      }

      rootIndexSizeKB +=
          (int) (store.getStorefilesIndexSize() / 1024);

      totalStaticIndexSizeKB +=
        (int) (store.getTotalStaticIndexSize() / 1024);

      totalStaticBloomSizeKB +=
        (int) (store.getTotalStaticBloomSize() / 1024);
    }
  }
  return new HServerLoad.RegionLoad(name, stores, storefiles,
      storeUncompressedSizeMB,
      storefileSizeMB, memstoreSizeMB, storefileIndexSizeMB, rootIndexSizeKB,
      totalStaticIndexSizeKB, totalStaticBloomSizeKB,
      (int) r.readRequestsCount.get(), (int) r.writeRequestsCount.get(),
      totalCompactingKVs, currentCompactedKVs);
}

项目：IRIndex 文件：Compactor.java

CompactionProgress getProgress() {
  return this.progress;
}

项目：IRIndex 文件：Store.java

/** getter for CompactionProgress object
 * @return CompactionProgress object; can be null
 */
public CompactionProgress getCompactionProgress() {
  return this.compactor.getProgress();
}

项目：hbase 文件：HRegionServer.java

RegionLoad createRegionLoad(final HRegion r, RegionLoad.Builder regionLoadBldr,
    RegionSpecifier.Builder regionSpecifier) throws IOException {
  byte[] name = r.getRegionInfo().getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.getMemStoreSize() / 1024 / 1024);
  long storefileIndexSizeKB = 0;
  int rootLevelIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  List<HStore> storeList = r.getStores();
  stores += storeList.size();
  for (HStore store : storeList) {
    storefiles += store.getStorefilesCount();
    storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed() / 1024 / 1024);
    storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
    //TODO: storefileIndexSizeKB is same with rootLevelIndexSizeKB?
    storefileIndexSizeKB += store.getStorefilesRootLevelIndexSize() / 1024;
    CompactionProgress progress = store.getCompactionProgress();
    if (progress != null) {
      totalCompactingKVs += progress.totalCompactingKVs;
      currentCompactedKVs += progress.currentCompactedKVs;
    }
    rootLevelIndexSizeKB += (int) (store.getStorefilesRootLevelIndexSize() / 1024);
    totalStaticIndexSizeKB += (int) (store.getTotalStaticIndexSize() / 1024);
    totalStaticBloomSizeKB += (int) (store.getTotalStaticBloomSize() / 1024);
  }

  float dataLocality =
      r.getHDFSBlocksDistribution().getBlockLocalityIndex(serverName.getHostname());
  if (regionLoadBldr == null) {
    regionLoadBldr = RegionLoad.newBuilder();
  }
  if (regionSpecifier == null) {
    regionSpecifier = RegionSpecifier.newBuilder();
  }
  regionSpecifier.setType(RegionSpecifierType.REGION_NAME);
  regionSpecifier.setValue(UnsafeByteOperations.unsafeWrap(name));
  regionLoadBldr.setRegionSpecifier(regionSpecifier.build())
    .setStores(stores)
    .setStorefiles(storefiles)
    .setStoreUncompressedSizeMB(storeUncompressedSizeMB)
    .setStorefileSizeMB(storefileSizeMB)
    .setMemStoreSizeMB(memstoreSizeMB)
    .setStorefileIndexSizeKB(storefileIndexSizeKB)
    .setRootIndexSizeKB(rootLevelIndexSizeKB)
    .setTotalStaticIndexSizeKB(totalStaticIndexSizeKB)
    .setTotalStaticBloomSizeKB(totalStaticBloomSizeKB)
    .setReadRequestsCount(r.getReadRequestsCount())
    .setFilteredReadRequestsCount(r.getFilteredReadRequestsCount())
    .setWriteRequestsCount(r.getWriteRequestsCount())
    .setTotalCompactingKVs(totalCompactingKVs)
    .setCurrentCompactedKVs(currentCompactedKVs)
    .setDataLocality(dataLocality)
    .setLastMajorCompactionTs(r.getOldestHfileTs(true));
  r.setCompleteSequenceId(regionLoadBldr);

  return regionLoadBldr.build();
}

项目：RStore 文件：HRegionServer.java

private HServerLoad.RegionLoad createRegionLoad(final HRegion r) {
  byte[] name = r.getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  synchronized (r.stores) {
    stores += r.stores.size();
    for (Store store : r.stores.values()) {
      storefiles += store.getStorefilesCount();
      storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
          / 1024 / 1024);
      storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
      storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
      CompactionProgress progress = store.getCompactionProgress();
      if (progress != null) {
        totalCompactingKVs += progress.totalCompactingKVs;
        currentCompactedKVs += progress.currentCompactedKVs;
      }

      rootIndexSizeKB +=
          (int) (store.getStorefilesIndexSize() / 1024);

      totalStaticIndexSizeKB +=
        (int) (store.getTotalStaticIndexSize() / 1024);

      totalStaticBloomSizeKB +=
        (int) (store.getTotalStaticBloomSize() / 1024);
    }
  }
  return new HServerLoad.RegionLoad(name, stores, storefiles,
      storeUncompressedSizeMB,
      storefileSizeMB, memstoreSizeMB, storefileIndexSizeMB, rootIndexSizeKB,
      totalStaticIndexSizeKB, totalStaticBloomSizeKB,
      (int) r.readRequestsCount.get(), (int) r.writeRequestsCount.get(),
      totalCompactingKVs, currentCompactedKVs,
      r.getCoprocessorHost().getCoprocessors());
}

项目：RStore 文件：Store.java

/** getter for CompactionProgress object
 * @return CompactionProgress object
 */
public CompactionProgress getCompactionProgress() {
  return this.progress;
}

项目：PyroDB 文件：HRegionServer.java

private RegionLoad createRegionLoad(final HRegion r, RegionLoad.Builder regionLoadBldr,
    RegionSpecifier.Builder regionSpecifier) {
  byte[] name = r.getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  synchronized (r.stores) {
    stores += r.stores.size();
    for (Store store : r.stores.values()) {
      storefiles += store.getStorefilesCount();
      storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
          / 1024 / 1024);
      storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
      storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
      CompactionProgress progress = store.getCompactionProgress();
      if (progress != null) {
        totalCompactingKVs += progress.totalCompactingKVs;
        currentCompactedKVs += progress.currentCompactedKVs;
      }

      rootIndexSizeKB +=
          (int) (store.getStorefilesIndexSize() / 1024);

      totalStaticIndexSizeKB +=
        (int) (store.getTotalStaticIndexSize() / 1024);

      totalStaticBloomSizeKB +=
        (int) (store.getTotalStaticBloomSize() / 1024);
    }
  }
  if (regionLoadBldr == null) {
    regionLoadBldr = RegionLoad.newBuilder();
  }
  if (regionSpecifier == null) {
    regionSpecifier = RegionSpecifier.newBuilder();
  }
  regionSpecifier.setType(RegionSpecifierType.REGION_NAME);
  regionSpecifier.setValue(HBaseZeroCopyByteString.wrap(name));
  regionLoadBldr.setRegionSpecifier(regionSpecifier.build())
    .setStores(stores)
    .setStorefiles(storefiles)
    .setStoreUncompressedSizeMB(storeUncompressedSizeMB)
    .setStorefileSizeMB(storefileSizeMB)
    .setMemstoreSizeMB(memstoreSizeMB)
    .setStorefileIndexSizeMB(storefileIndexSizeMB)
    .setRootIndexSizeKB(rootIndexSizeKB)
    .setTotalStaticIndexSizeKB(totalStaticIndexSizeKB)
    .setTotalStaticBloomSizeKB(totalStaticBloomSizeKB)
    .setReadRequestsCount((int) r.readRequestsCount.get())
    .setWriteRequestsCount((int) r.writeRequestsCount.get())
    .setTotalCompactingKVs(totalCompactingKVs)
    .setCurrentCompactedKVs(currentCompactedKVs)
    .setCompleteSequenceId(r.lastFlushSeqId);

  return regionLoadBldr.build();
}

项目：PyroDB 文件：HStore.java

@Override
public CompactionProgress getCompactionProgress() {
  return this.storeEngine.getCompactor().getProgress();
}

项目：c5 文件：HRegionServer.java

private RegionLoad createRegionLoad(final HRegion r) {
  byte[] name = r.getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  synchronized (r.stores) {
    stores += r.stores.size();
    for (Store store : r.stores.values()) {
      storefiles += store.getStorefilesCount();
      storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
          / 1024 / 1024);
      storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
      storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
      CompactionProgress progress = store.getCompactionProgress();
      if (progress != null) {
        totalCompactingKVs += progress.totalCompactingKVs;
        currentCompactedKVs += progress.currentCompactedKVs;
      }

      rootIndexSizeKB +=
          (int) (store.getStorefilesIndexSize() / 1024);

      totalStaticIndexSizeKB +=
        (int) (store.getTotalStaticIndexSize() / 1024);

      totalStaticBloomSizeKB +=
        (int) (store.getTotalStaticBloomSize() / 1024);
    }
  }
  RegionLoad.Builder regionLoad = RegionLoad.newBuilder();
  RegionSpecifier.Builder regionSpecifier = RegionSpecifier.newBuilder();
  regionSpecifier.setType(RegionSpecifierType.REGION_NAME);
  regionSpecifier.setValue(ZeroCopyLiteralByteString.wrap(name));
  regionLoad.setRegionSpecifier(regionSpecifier.build())
    .setStores(stores)
    .setStorefiles(storefiles)
    .setStoreUncompressedSizeMB(storeUncompressedSizeMB)
    .setStorefileSizeMB(storefileSizeMB)
    .setMemstoreSizeMB(memstoreSizeMB)
    .setStorefileIndexSizeMB(storefileIndexSizeMB)
    .setRootIndexSizeKB(rootIndexSizeKB)
    .setTotalStaticIndexSizeKB(totalStaticIndexSizeKB)
    .setTotalStaticBloomSizeKB(totalStaticBloomSizeKB)
    .setReadRequestsCount((int) r.readRequestsCount.get())
    .setWriteRequestsCount((int) r.writeRequestsCount.get())
    .setTotalCompactingKVs(totalCompactingKVs)
    .setCurrentCompactedKVs(currentCompactedKVs)
    .setCompleteSequenceId(r.completeSequenceId);

  return regionLoad.build();
}

项目：c5 文件：HStore.java

@Override
public CompactionProgress getCompactionProgress() {
  return this.storeEngine.getCompactor().getProgress();
}

项目：HBase-Research 文件：HRegionServer.java

private HServerLoad.RegionLoad createRegionLoad(final HRegion r) {
  byte[] name = r.getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  synchronized (r.stores) {
    stores += r.stores.size();
    for (Store store : r.stores.values()) {
      storefiles += store.getStorefilesCount();
      storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
          / 1024 / 1024);
      storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
      storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
      CompactionProgress progress = store.getCompactionProgress();
      if (progress != null) {
        totalCompactingKVs += progress.totalCompactingKVs;
        currentCompactedKVs += progress.currentCompactedKVs;
      }

      rootIndexSizeKB +=
          (int) (store.getStorefilesIndexSize() / 1024);

      totalStaticIndexSizeKB +=
        (int) (store.getTotalStaticIndexSize() / 1024);

      totalStaticBloomSizeKB +=
        (int) (store.getTotalStaticBloomSize() / 1024);
    }
  }
  return new HServerLoad.RegionLoad(name, stores, storefiles,
      storeUncompressedSizeMB,
      storefileSizeMB, memstoreSizeMB, storefileIndexSizeMB, rootIndexSizeKB,
      totalStaticIndexSizeKB, totalStaticBloomSizeKB,
      (int) r.readRequestsCount.get(), (int) r.writeRequestsCount.get(),
      totalCompactingKVs, currentCompactedKVs);
}

项目：HBase-Research 文件：Compactor.java

CompactionProgress getProgress() {
  return this.progress;
}

项目：HBase-Research 文件：Store.java

/** getter for CompactionProgress object
 * @return CompactionProgress object; can be null
 */
public CompactionProgress getCompactionProgress() {
  return this.compactor.getProgress();
}

项目：hbase-0.94.8-qod 文件：HRegionServer.java

private HServerLoad.RegionLoad createRegionLoad(final HRegion r) {
  byte[] name = r.getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  synchronized (r.stores) {
    stores += r.stores.size();
    for (Store store : r.stores.values()) {
      storefiles += store.getStorefilesCount();
      storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
          / 1024 / 1024);
      storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
      storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
      CompactionProgress progress = store.getCompactionProgress();
      if (progress != null) {
        totalCompactingKVs += progress.totalCompactingKVs;
        currentCompactedKVs += progress.currentCompactedKVs;
      }

      rootIndexSizeKB +=
          (int) (store.getStorefilesIndexSize() / 1024);

      totalStaticIndexSizeKB +=
        (int) (store.getTotalStaticIndexSize() / 1024);

      totalStaticBloomSizeKB +=
        (int) (store.getTotalStaticBloomSize() / 1024);
    }
  }
  return new HServerLoad.RegionLoad(name, stores, storefiles,
      storeUncompressedSizeMB,
      storefileSizeMB, memstoreSizeMB, storefileIndexSizeMB, rootIndexSizeKB,
      totalStaticIndexSizeKB, totalStaticBloomSizeKB,
      (int) r.readRequestsCount.get(), (int) r.writeRequestsCount.get(),
      totalCompactingKVs, currentCompactedKVs);
}

项目：hbase-0.94.8-qod 文件：Compactor.java

CompactionProgress getProgress() {
  return this.progress;
}

项目：hbase-0.94.8-qod 文件：Store.java

/** getter for CompactionProgress object
 * @return CompactionProgress object; can be null
 */
public CompactionProgress getCompactionProgress() {
  return this.compactor.getProgress();
}

项目：hbase-0.94.8-qod 文件：HRegionServer.java

private HServerLoad.RegionLoad createRegionLoad(final HRegion r) {
  byte[] name = r.getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  synchronized (r.stores) {
    stores += r.stores.size();
    for (Store store : r.stores.values()) {
      storefiles += store.getStorefilesCount();
      storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
          / 1024 / 1024);
      storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
      storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
      CompactionProgress progress = store.getCompactionProgress();
      if (progress != null) {
        totalCompactingKVs += progress.totalCompactingKVs;
        currentCompactedKVs += progress.currentCompactedKVs;
      }

      rootIndexSizeKB +=
          (int) (store.getStorefilesIndexSize() / 1024);

      totalStaticIndexSizeKB +=
        (int) (store.getTotalStaticIndexSize() / 1024);

      totalStaticBloomSizeKB +=
        (int) (store.getTotalStaticBloomSize() / 1024);
    }
  }
  return new HServerLoad.RegionLoad(name, stores, storefiles,
      storeUncompressedSizeMB,
      storefileSizeMB, memstoreSizeMB, storefileIndexSizeMB, rootIndexSizeKB,
      totalStaticIndexSizeKB, totalStaticBloomSizeKB,
      (int) r.readRequestsCount.get(), (int) r.writeRequestsCount.get(),
      totalCompactingKVs, currentCompactedKVs);
}

项目：hbase-0.94.8-qod 文件：Compactor.java

CompactionProgress getProgress() {
  return this.progress;
}

项目：hbase-0.94.8-qod 文件：Store.java

/** getter for CompactionProgress object
 * @return CompactionProgress object; can be null
 */
public CompactionProgress getCompactionProgress() {
  return this.compactor.getProgress();
}

项目：DominoHBase 文件：HRegionServer.java

private RegionLoad createRegionLoad(final HRegion r) {
  byte[] name = r.getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  synchronized (r.stores) {
    stores += r.stores.size();
    for (Store store : r.stores.values()) {
      storefiles += store.getStorefilesCount();
      storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
          / 1024 / 1024);
      storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
      storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
      CompactionProgress progress = store.getCompactionProgress();
      if (progress != null) {
        totalCompactingKVs += progress.totalCompactingKVs;
        currentCompactedKVs += progress.currentCompactedKVs;
      }

      rootIndexSizeKB +=
          (int) (store.getStorefilesIndexSize() / 1024);

      totalStaticIndexSizeKB +=
        (int) (store.getTotalStaticIndexSize() / 1024);

      totalStaticBloomSizeKB +=
        (int) (store.getTotalStaticBloomSize() / 1024);
    }
  }
  RegionLoad.Builder regionLoad = RegionLoad.newBuilder();
  RegionSpecifier.Builder regionSpecifier = RegionSpecifier.newBuilder();
  regionSpecifier.setType(RegionSpecifierType.REGION_NAME);
  regionSpecifier.setValue(ByteString.copyFrom(name));
  regionLoad.setRegionSpecifier(regionSpecifier.build())
    .setStores(stores)
    .setStorefiles(storefiles)
    .setStoreUncompressedSizeMB(storeUncompressedSizeMB)
    .setStorefileSizeMB(storefileSizeMB)
    .setMemstoreSizeMB(memstoreSizeMB)
    .setStorefileIndexSizeMB(storefileIndexSizeMB)
    .setRootIndexSizeKB(rootIndexSizeKB)
    .setTotalStaticIndexSizeKB(totalStaticIndexSizeKB)
    .setTotalStaticBloomSizeKB(totalStaticBloomSizeKB)
    .setReadRequestsCount((int) r.readRequestsCount.get())
    .setWriteRequestsCount((int) r.writeRequestsCount.get())
    .setTotalCompactingKVs(totalCompactingKVs)
    .setCurrentCompactedKVs(currentCompactedKVs)
    .setCompleteSequenceId(r.completeSequenceId);

  return regionLoad.build();
}

项目：DominoHBase 文件：Compactor.java

CompactionProgress getProgress() {
  return this.progress;
}

项目：DominoHBase 文件：HStore.java

@Override
public CompactionProgress getCompactionProgress() {
  return this.compactor.getProgress();
}

项目：spliceengine 文件：SpliceDefaultCompactor.java

@Override
public CompactionProgress getProgress() {
    return super.getProgress();
}

项目：spliceengine 文件：SpliceDefaultCompactor.java

@Override
public CompactionProgress getProgress() {
    return super.getProgress();
}

项目：hindex 文件：HRegionServer.java

private HServerLoad.RegionLoad createRegionLoad(final HRegion r) {
  byte[] name = r.getRegionName();
  int stores = 0;
  int storefiles = 0;
  int storeUncompressedSizeMB = 0;
  int storefileSizeMB = 0;
  int memstoreSizeMB = (int) (r.memstoreSize.get() / 1024 / 1024);
  int storefileIndexSizeMB = 0;
  int rootIndexSizeKB = 0;
  int totalStaticIndexSizeKB = 0;
  int totalStaticBloomSizeKB = 0;
  long totalCompactingKVs = 0;
  long currentCompactedKVs = 0;
  synchronized (r.stores) {
    stores += r.stores.size();
    for (Store store : r.stores.values()) {
      storefiles += store.getStorefilesCount();
      storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
          / 1024 / 1024);
      storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
      storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
      CompactionProgress progress = store.getCompactionProgress();
      if (progress != null) {
        totalCompactingKVs += progress.totalCompactingKVs;
        currentCompactedKVs += progress.currentCompactedKVs;
      }

      rootIndexSizeKB +=
          (int) (store.getStorefilesIndexSize() / 1024);

      totalStaticIndexSizeKB +=
        (int) (store.getTotalStaticIndexSize() / 1024);

      totalStaticBloomSizeKB +=
        (int) (store.getTotalStaticBloomSize() / 1024);
    }
  }
  return new HServerLoad.RegionLoad(name, stores, storefiles,
      storeUncompressedSizeMB,
      storefileSizeMB, memstoreSizeMB, storefileIndexSizeMB, rootIndexSizeKB,
      totalStaticIndexSizeKB, totalStaticBloomSizeKB,
      (int) r.readRequestsCount.get(), (int) r.writeRequestsCount.get(),
      totalCompactingKVs, currentCompactedKVs);
}

项目：hindex 文件：Compactor.java

CompactionProgress getProgress() {
  return this.progress;
}

项目：hindex 文件：Store.java

/** getter for CompactionProgress object
 * @return CompactionProgress object; can be null
 */
public CompactionProgress getCompactionProgress() {
  return this.compactor.getProgress();
}

项目：ditb 文件：Store.java

/**
 * getter for CompactionProgress object
 * 
 * @return CompactionProgress object; can be null
 */
CompactionProgress getCompactionProgress();

项目：LCIndex-HBase-0.94.16 文件：Store.java

/**
 * getter for CompactionProgress object
 * @return CompactionProgress object; can be null
 */
public CompactionProgress getCompactionProgress() {
  return this.compactor.getProgress();
}

项目：pbase 文件：Store.java

/**
 * getter for CompactionProgress object
 * @return CompactionProgress object; can be null
 */
CompactionProgress getCompactionProgress();

项目：HIndex 文件：Store.java

/**
 * getter for CompactionProgress object
 * @return CompactionProgress object; can be null
 */
CompactionProgress getCompactionProgress();

项目：hbase 文件：HStore.java

/**
 * getter for CompactionProgress object
 * @return CompactionProgress object; can be null
 */
public CompactionProgress getCompactionProgress() {
  return this.storeEngine.getCompactor().getProgress();
}