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

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

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

Store.getStorefilesSize介绍

暂无

代码示例

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

private Region mockRegionWithHFileLinks(Collection<Long> storeSizes, Collection<Long> hfileSizes) {
 final Region r = mock(Region.class);
 final RegionInfo info = mock(RegionInfo.class);
 when(r.getRegionInfo()).thenReturn(info);
 List<Store> stores = new ArrayList<>();
 when(r.getStores()).thenReturn((List) stores);
 assertEquals(
   "Logic error, storeSizes and linkSizes must be equal in size", storeSizes.size(),
   hfileSizes.size());
 Iterator<Long> storeSizeIter = storeSizes.iterator();
 Iterator<Long> hfileSizeIter = hfileSizes.iterator();
 while (storeSizeIter.hasNext() && hfileSizeIter.hasNext()) {
  final long storeSize = storeSizeIter.next();
  final long hfileSize = hfileSizeIter.next();
  final Store s = mock(Store.class);
  stores.add(s);
  when(s.getStorefilesSize()).thenReturn(storeSize);
  when(s.getHFilesSize()).thenReturn(hfileSize);
 }
 return r;
}

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

mt.memstoreSize += (store.getMemStoreSize().getDataSize() +
 store.getMemStoreSize().getHeapSize() + store.getMemStoreSize().getOffHeapSize());
mt.storeFileSize += store.getStorefilesSize();
mt.referenceFileCount += store.getNumReferenceFiles();

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

tempNumStoreFiles += store.getStorefilesCount();
tempMemstoreSize += store.getMemStoreSize().getDataSize();
tempStoreFileSize += store.getStorefilesSize();
OptionalLong storeMaxStoreFileAge = store.getMaxStoreFileAge();
if (storeMaxStoreFileAge.isPresent() &&

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

tempNumStoreFiles += store.getStorefilesCount();
tempMemstoreSize += store.getMemStoreSize().getDataSize();
tempStoreFileSize += store.getStorefilesSize();

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

long summer = 0;
for (Store store : stores) {
 summer += store.getStorefilesSize();

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

@Override
 public void run() {
  long tempNumStoreFiles = 0;
  long tempMemstoreSize = 0;
  long tempStoreFileSize = 0;
  if (region.stores != null) {
   for (Store store : region.stores.values()) {
    tempNumStoreFiles += store.getStorefilesCount();
    tempMemstoreSize += store.getMemStoreSize();
    tempStoreFileSize += store.getStorefilesSize();
   }
  }
  numStoreFiles = tempNumStoreFiles;
  memstoreSize = tempMemstoreSize;
  storeFileSize = tempStoreFileSize;
 }
}

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

for (Store store : r.stores.values()) {
 storefiles += store.getStorefilesCount();
 storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
 storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);

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

private Region mockRegionWithHFileLinks(Collection<Long> storeSizes, Collection<Long> hfileSizes) {
 final Region r = mock(Region.class);
 final RegionInfo info = mock(RegionInfo.class);
 when(r.getRegionInfo()).thenReturn(info);
 List<Store> stores = new ArrayList<>();
 when(r.getStores()).thenReturn((List) stores);
 assertEquals(
   "Logic error, storeSizes and linkSizes must be equal in size", storeSizes.size(),
   hfileSizes.size());
 Iterator<Long> storeSizeIter = storeSizes.iterator();
 Iterator<Long> hfileSizeIter = hfileSizes.iterator();
 while (storeSizeIter.hasNext() && hfileSizeIter.hasNext()) {
  final long storeSize = storeSizeIter.next();
  final long hfileSize = hfileSizeIter.next();
  final Store s = mock(Store.class);
  stores.add(s);
  when(s.getStorefilesSize()).thenReturn(storeSize);
  when(s.getHFilesSize()).thenReturn(hfileSize);
 }
 return r;
}

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

storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
  / 1024 / 1024);
storefileSizeMB += (int) (store.getStorefilesSize() / 1024 / 1024);
storefileIndexSizeMB += (int) (store.getStorefilesIndexSize() / 1024 / 1024);
CompactionProgress progress = store.getCompactionProgress();

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

long tmpStorefilesSize = store.getStorefilesSize();
schemaMetrics.accumulateStoreMetric(tempVals,
  StoreMetricType.STORE_FILE_SIZE_MB,

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

tempNumStoreFiles += store.getStorefilesCount();
tempMemstoreSize += store.getMemStoreSize();
tempStoreFileSize += store.getStorefilesSize();
tempStorefileIndexSize += store.getStorefilesIndexSize();
tempTotalStaticBloomSize += store.getTotalStaticBloomSize();

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

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();

相关文章