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

x33g5p2x  于2022-01-20 转载在 其他  
字(12.8k)|赞(0)|评价(0)|浏览(146)

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

HStore.getMemStoreSize介绍

暂无

代码示例

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

protected boolean shouldFlush(HStore store) {
  if (store.getMemStoreSize().getHeapSize()
    + store.getMemStoreSize().getOffHeapSize() > this.flushSizeLowerBound) {
   LOG.debug("Flush {} of {}; "
       + "heap memstoreSize={} +"
       + "off heap memstoreSize={} > memstore lowerBound={}"
     , store.getColumnFamilyName()
     , region.getRegionInfo().getEncodedName()
     , store.getMemStoreSize().getHeapSize()
     , store.getMemStoreSize().getOffHeapSize()
     , this.flushSizeLowerBound
   );
   return true;
  }
  return false;
 }
}

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

void throwException(String title, String regionName) {
 StringBuilder buf = new StringBuilder();
 buf.append(title + ", ");
 buf.append(getRegionInfo().toString());
 buf.append(getRegionInfo().isMetaRegion() ? " meta region " : " ");
 buf.append("stores: ");
 for (HStore s : stores.values()) {
  buf.append(s.getColumnFamilyDescriptor().getNameAsString());
  buf.append(" size: ");
  buf.append(s.getMemStoreSize().getDataSize());
  buf.append(" ");
 }
 buf.append("end-of-stores");
 buf.append(", memstore size ");
 buf.append(getMemStoreDataSize());
 if (getRegionInfo().getRegionNameAsString().startsWith(regionName)) {
  throw new RuntimeException(buf.toString());
 }
}

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

assertTrue(desiredRegion.getStore(FAMILY1).getMemStoreSize().getHeapSize() > cfFlushSizeLowerBound);
assertTrue(desiredRegion.getStore(FAMILY2).getMemStoreSize().getHeapSize() < cfFlushSizeLowerBound);
assertTrue(desiredRegion.getStore(FAMILY3).getMemStoreSize().getHeapSize() < cfFlushSizeLowerBound);
table.put(createPut(1, 12345678));
 desiredRegion.getStore(FAMILY1).getMemStoreSize().getHeapSize());
assertEquals(MutableSegment.DEEP_OVERHEAD,
 desiredRegion.getStore(FAMILY2).getMemStoreSize().getHeapSize());
assertEquals(MutableSegment.DEEP_OVERHEAD,
 desiredRegion.getStore(FAMILY3).getMemStoreSize().getHeapSize());

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

MemStoreSize cf1MemstoreSize = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSize = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
cf1MemstoreSize = region.getStore(FAMILY1).getMemStoreSize();
cf2MemstoreSize = region.getStore(FAMILY2).getMemStoreSize();
cf3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
totalMemstoreSize = region.getMemStoreDataSize();
long smallestSeqInRegionCurrentMemstore =

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

cf1MemstoreSize = desiredRegion.getStore(FAMILY1).getMemStoreSize().getDataSize();
cf2MemstoreSize = desiredRegion.getStore(FAMILY2).getMemStoreSize().getDataSize();
cf3MemstoreSize = desiredRegion.getStore(FAMILY3).getMemStoreSize().getDataSize();

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

long storeMemstoreSize = store.getMemStoreSize().getHeapSize();
long regionMemstoreSize = secondaryRegion.getMemStoreDataSize();
MemStoreSize mss = store.getFlushableSize();
 long newStoreMemstoreSize = store.getMemStoreSize().getHeapSize();
 LOG.info("Memstore size reduced by:"
   + StringUtils.humanReadableInt(newStoreMemstoreSize - storeMemstoreSize));

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

MemStoreSize cf1MemstoreSize = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSize = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
cf1MemstoreSize = region.getStore(FAMILY1).getMemStoreSize();
cf2MemstoreSize = region.getStore(FAMILY2).getMemStoreSize();
cf3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
totalMemstoreSize = region.getMemStoreDataSize();
smallestSeqInRegionCurrentMemstore = getWAL(region)
oldCF3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
cf1MemstoreSize = region.getStore(FAMILY1).getMemStoreSize();
cf2MemstoreSize = region.getStore(FAMILY2).getMemStoreSize();
cf3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
totalMemstoreSize = region.getMemStoreDataSize();
smallestSeqInRegionCurrentMemstore = getWAL(region)

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

long storeMemstoreSize = store.getMemStoreSize().getHeapSize();
long regionMemstoreSize = secondaryRegion.getMemStoreDataSize();
MemStoreSize mss = store.getFlushableSize();
 long newStoreMemstoreSize = store.getMemStoreSize().getHeapSize();
 LOG.info("Memstore size reduced by:"
   + StringUtils.humanReadableInt(newStoreMemstoreSize - storeMemstoreSize));

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

MemStoreSize cf1MemstoreSizePhaseI = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseI = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseI = region.getStore(FAMILY3).getMemStoreSize();
MemStoreSize cf1MemstoreSizePhaseII = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseII = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseII = region.getStore(FAMILY3).getMemStoreSize();
long smallestSeqInRegionCurrentMemstorePhaseII = getWAL(region)
  .getEarliestMemStoreSeqNum(region.getRegionInfo().getEncodedNameAsBytes());
MemStoreSize cf1MemstoreSizePhaseIII = region.getStore(FAMILY1).getMemStoreSize();
long totalMemstoreSizePhaseIII = region.getMemStoreDataSize();
MemStoreSize cf1MemstoreSizePhaseIV = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseIV = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseIV = region.getStore(FAMILY3).getMemStoreSize();
long smallestSeqInRegionCurrentMemstorePhaseIV = getWAL(region)
  .getEarliestMemStoreSeqNum(region.getRegionInfo().getEncodedNameAsBytes());
MemStoreSize cf1MemstoreSizePhaseV = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseV = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseV = region.getStore(FAMILY3).getMemStoreSize();
long smallestSeqInRegionCurrentMemstorePhaseV = getWAL(region)
  .getEarliestMemStoreSeqNum(region.getRegionInfo().getEncodedNameAsBytes());
MemStoreSize cf1ActiveSizePhaseVI = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf3ActiveSizePhaseVI = region.getStore(FAMILY3).getMemStoreSize();
MemStoreSize cf5ActiveSizePhaseVI = region.getStore(FAMILIES[4]).getMemStoreSize();

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

MemStoreSize cf1MemstoreSizePhaseI = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseI = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseI = region.getStore(FAMILY3).getMemStoreSize();
MemStoreSize cf1MemstoreSizePhaseII = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseII = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseII = region.getStore(FAMILY3).getMemStoreSize();
MemStoreSize cf1MemstoreSizePhaseIII = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf1MemstoreSizePhaseIV = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseIV = region.getStore(FAMILY2).getMemStoreSize();

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

MemStoreSize cf1MemstoreSizePhaseI = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseI = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseI = region.getStore(FAMILY3).getMemStoreSize();
MemStoreSize cf1MemstoreSizePhaseII = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseII = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseII = region.getStore(FAMILY3).getMemStoreSize();
MemStoreSize cf1MemstoreSizePhaseIII = region.getStore(FAMILY1).getMemStoreSize();
long smallestSeqCF1PhaseIII = region.getOldestSeqIdOfStore(FAMILY1);
MemStoreSize cf1MemstoreSizePhaseIV = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseIV = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseIV = region.getStore(FAMILY3).getMemStoreSize();
MemStoreSize cf1MemstoreSizePhaseV = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseV = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseV = region.getStore(FAMILY3).getMemStoreSize();
long smallestSeqInRegionCurrentMemstorePhaseV = getWAL(region)
  .getEarliestMemStoreSeqNum(region.getRegionInfo().getEncodedNameAsBytes());

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

MemStoreSize cf1MemstoreSizePhaseI = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseI = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseI = region.getStore(FAMILY3).getMemStoreSize();
region.flush(false);
MemStoreSize cf2MemstoreSizePhaseII = region.getStore(FAMILY2).getMemStoreSize();

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

assertTrue(desiredRegion.getStore(FAMILY1).getMemStoreSize().getHeapSize() > cfFlushSizeLowerBound);
assertTrue(desiredRegion.getStore(FAMILY2).getMemStoreSize().getHeapSize() < cfFlushSizeLowerBound);
assertTrue(desiredRegion.getStore(FAMILY3).getMemStoreSize().getHeapSize() < cfFlushSizeLowerBound);
table.put(createPut(1, 12345678));
 desiredRegion.getStore(FAMILY1).getMemStoreSize().getHeapSize());
assertEquals(MutableSegment.DEEP_OVERHEAD,
 desiredRegion.getStore(FAMILY2).getMemStoreSize().getHeapSize());
assertEquals(MutableSegment.DEEP_OVERHEAD,
 desiredRegion.getStore(FAMILY3).getMemStoreSize().getHeapSize());

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

MemStoreSize cf1MemstoreSize = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSize = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
cf1MemstoreSize = region.getStore(FAMILY1).getMemStoreSize();
cf2MemstoreSize = region.getStore(FAMILY2).getMemStoreSize();
cf3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
totalMemstoreSize = region.getMemStoreDataSize();
long smallestSeqInRegionCurrentMemstore =

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

cf1MemstoreSize = desiredRegion.getStore(FAMILY1).getMemStoreSize().getDataSize();
cf2MemstoreSize = desiredRegion.getStore(FAMILY2).getMemStoreSize().getDataSize();
cf3MemstoreSize = desiredRegion.getStore(FAMILY3).getMemStoreSize().getDataSize();

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

long storeMemstoreSize = store.getMemStoreSize().getHeapSize();
long regionMemstoreSize = secondaryRegion.getMemStoreDataSize();
MemStoreSize mss = store.getFlushableSize();
 long newStoreMemstoreSize = store.getMemStoreSize().getHeapSize();
 LOG.info("Memstore size reduced by:"
   + StringUtils.humanReadableInt(newStoreMemstoreSize - storeMemstoreSize));

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

MemStoreSize cf1MemstoreSize = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSize = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
cf1MemstoreSize = region.getStore(FAMILY1).getMemStoreSize();
cf2MemstoreSize = region.getStore(FAMILY2).getMemStoreSize();
cf3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
totalMemstoreSize = region.getMemStoreDataSize();
smallestSeqInRegionCurrentMemstore = getWAL(region)
oldCF3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
cf1MemstoreSize = region.getStore(FAMILY1).getMemStoreSize();
cf2MemstoreSize = region.getStore(FAMILY2).getMemStoreSize();
cf3MemstoreSize = region.getStore(FAMILY3).getMemStoreSize();
totalMemstoreSize = region.getMemStoreDataSize();
smallestSeqInRegionCurrentMemstore = getWAL(region)

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

long storeMemstoreSize = store.getMemStoreSize().getHeapSize();
long regionMemstoreSize = secondaryRegion.getMemStoreDataSize();
MemStoreSize mss = store.getFlushableSize();
 long newStoreMemstoreSize = store.getMemStoreSize().getHeapSize();
 LOG.info("Memstore size reduced by:"
   + StringUtils.humanReadableInt(newStoreMemstoreSize - storeMemstoreSize));

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

MemStoreSize cf1MemstoreSizePhaseI = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseI = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseI = region.getStore(FAMILY3).getMemStoreSize();
MemStoreSize cf1MemstoreSizePhaseII = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseII = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseII = region.getStore(FAMILY3).getMemStoreSize();
MemStoreSize cf1MemstoreSizePhaseIII = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf1MemstoreSizePhaseIV = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseIV = region.getStore(FAMILY2).getMemStoreSize();

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

MemStoreSize cf1MemstoreSizePhaseI = region.getStore(FAMILY1).getMemStoreSize();
MemStoreSize cf2MemstoreSizePhaseI = region.getStore(FAMILY2).getMemStoreSize();
MemStoreSize cf3MemstoreSizePhaseI = region.getStore(FAMILY3).getMemStoreSize();
region.flush(false);
MemStoreSize cf2MemstoreSizePhaseII = region.getStore(FAMILY2).getMemStoreSize();

内容来源于网络，如有侵权，请联系作者删除！

HStore

相关文章

    查看更多

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多

    HStore类方法

    • 蜀ICP备2022004421号-2 NULL123 https://www.null123.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com