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

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

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

Store.getMemStoreSize介绍

暂无

代码示例

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

for (Store store : r.getStores()) {
 mt.storeFileCount += store.getStorefilesCount();
 mt.memstoreSize += (store.getMemStoreSize().getDataSize() +
  store.getMemStoreSize().getHeapSize() + store.getMemStoreSize().getOffHeapSize());
 mt.storeFileSize += store.getStorefilesSize();
 mt.referenceFileCount += store.getNumReferenceFiles();

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

for (Store store : region.stores.values()) {
 tempNumStoreFiles += store.getStorefilesCount();
 tempMemstoreSize += store.getMemStoreSize().getDataSize();
 tempStoreFileSize += store.getStorefilesSize();
 OptionalLong storeMaxStoreFileAge = store.getMaxStoreFileAge();

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

for (Store store : storeList) {
 tempNumStoreFiles += store.getStorefilesCount();
 tempMemstoreSize += store.getMemStoreSize().getDataSize();
 tempStoreFileSize += store.getStorefilesSize();

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

out.print( cf );
 out.write("</h3>\n\n       <h4>Memstore size (MB): ");
 out.print( (int) (store.getMemStoreSize().getHeapSize() / 1024 / 1024) );
 out.write("</h4>\n\n       <h4>Store Files</h4>\n\n       <table class=\"table table-striped\">\n         <tr>\n           <th>Store File</th>\n           <th>Size (MB)</th>\n           <th>Modification time</th>\n         </tr>\n       ");
for(StoreFile sf : storeFiles) {

代码示例来源: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: harbby/presto-connectors

private boolean shouldFlush(Store store) {
 if (store.getMemStoreSize() > this.flushSizeLowerBound) {
  if (LOG.isDebugEnabled()) {
   LOG.debug("Flush Column Family " + store.getColumnFamilyName() + " of " +
    region.getRegionInfo().getEncodedName() + " because memstoreSize=" +
    store.getMemStoreSize() + " > lower bound=" + this.flushSizeLowerBound);
  }
  return true;
 }
 return region.shouldFlushStore(store);
}

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

for (Store store: storesToFlush) {
 perCfExtras.append("; ").append(store.getColumnFamilyName());
 perCfExtras.append("=").append(StringUtils.byteDesc(store.getMemStoreSize()));

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

(long) (store.getMemStoreSize() / (1024.0 * 1024)));

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

out.print( cf );
 out.write("</h2>\n\n       <h4>Memstore size (MB): ");
 out.print( (int) (store.getMemStoreSize() / 1024 / 1024) );
 out.write("</h3>\n\n       <h4>Store Files</h3>\n\n       <table class=\"table table-striped\">\n         <tr>\n           <th>Store File</th>\n           <th>Size (MB)</th>\n           <th>Modification time</th>\n         </tr>\n       ");
for(StoreFile sf : storeFiles) {

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

for (Store store : storeList) {
 tempNumStoreFiles += store.getStorefilesCount();
 tempMemstoreSize += store.getMemStoreSize();
 tempStoreFileSize += store.getStorefilesSize();
 tempStorefileIndexSize += store.getStorefilesIndexSize();

相关文章