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

HStore.getFlushableSize介绍

暂无

代码示例

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

/**
 * Utility method broken out of internalPrepareFlushCache so that method is smaller.
 */
private void logFatLineOnFlush(Collection<HStore> storesToFlush, long sequenceId) {
 if (!LOG.isInfoEnabled()) {
  return;
 }
 // Log a fat line detailing what is being flushed.
 StringBuilder perCfExtras = null;
 if (!isAllFamilies(storesToFlush)) {
  perCfExtras = new StringBuilder();
  for (HStore store: storesToFlush) {
   MemStoreSize mss = store.getFlushableSize();
   perCfExtras.append("; ").append(store.getColumnFamilyName());
   perCfExtras.append("={dataSize=")
     .append(StringUtils.byteDesc(mss.getDataSize()));
   perCfExtras.append(", heapSize=")
     .append(StringUtils.byteDesc(mss.getHeapSize()));
   perCfExtras.append(", offHeapSize=")
     .append(StringUtils.byteDesc(mss.getOffHeapSize()));
   perCfExtras.append("}");
  }
 }
 MemStoreSize mss = this.memStoreSizing.getMemStoreSize();
 LOG.info("Flushing " + + storesToFlush.size() + "/" + stores.size() + " column families," +
   " dataSize=" + StringUtils.byteDesc(mss.getDataSize()) +
   " heapSize=" + StringUtils.byteDesc(mss.getHeapSize()) +
   ((perCfExtras != null && perCfExtras.length() > 0)? perCfExtras.toString(): "") +
   ((wal != null) ? "" : "; WAL is null, using passed sequenceid=" + sequenceId));
}

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

private MemStoreSize doDropStoreMemStoreContentsForSeqId(HStore s, long currentSeqId)
  throws IOException {
 MemStoreSize flushableSize = s.getFlushableSize();
 this.decrMemStoreSize(flushableSize);
 StoreFlushContext ctx = s.createFlushContext(currentSeqId, FlushLifeCycleTracker.DUMMY);
 ctx.prepare();
 ctx.abort();
 return flushableSize;
}

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

store.getColumnFamilyDescriptor().getName());
if (ctx != null) {
 MemStoreSize mss = store.getFlushableSize();
 ctx.abort();
 this.decrMemStoreSize(mss);

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

MemStoreSize mss = store.getFlushableSize();
if (!(abort || mss.getDataSize() == 0 || writestate.readOnly)) {
 if (getRegionServerServices() != null) {

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

expectedSize, region.getMemStoreDataSize());
assertEquals("flushable size should be incremented",
  expectedSize, store.getFlushableSize().getDataSize());

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

assertTrue("The regionserver should have thrown an exception", threwIOE);
MemStoreSize mss = store.getFlushableSize();
assertTrue("flushable size should be zero, but it is " + mss,
  mss.getDataSize() == 0);

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

null : this.prepareFlushResult.storeFlushCtxs.get(family);
if (ctx != null) {
 MemStoreSize mss = store.getFlushableSize();
 ctx.abort();
 this.decrMemStoreSize(mss);

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

MemStoreSize mss = store.getFlushableSize();
assertTrue(mss.getHeapSize() == MutableSegment.DEEP_OVERHEAD);

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

MemStoreSize mss = store.getFlushableSize();
assertTrue(mss.getHeapSize() > 0); // assert that the memstore is not dropped

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

long storeMemstoreSize = store.getMemStoreSize().getHeapSize();
long regionMemstoreSize = secondaryRegion.getMemStoreDataSize();
MemStoreSize mss = store.getFlushableSize();
long storeSize = store.getSize();
long storeSizeUncompressed = store.getStoreSizeUncompressed();
  assertEquals(expectedStoreFileCount, s.getStorefilesCount());
 MemStoreSize newMss = store.getFlushableSize();
 assertTrue(mss.getHeapSize() > newMss.getHeapSize());

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

MemStoreSize mss = store.getFlushableSize();
assertTrue(mss.getHeapSize() > 0); // assert that the memstore is not dropped

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

MemStoreSize mss = store.getFlushableSize();
if (droppableMemstore) {

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

long storeMemstoreSize = store.getMemStoreSize().getHeapSize();
long regionMemstoreSize = secondaryRegion.getMemStoreDataSize();
MemStoreSize mss = store.getFlushableSize();

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

expectedSize, region.getMemStoreDataSize());
assertEquals("flushable size should be incremented",
  expectedSize, store.getFlushableSize().getDataSize());

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

assertTrue("The regionserver should have thrown an exception", threwIOE);
MemStoreSize mss = store.getFlushableSize();
assertTrue("flushable size should be zero, but it is " + mss,
  mss.getDataSize() == 0);

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

MemStoreSize mss = store.getFlushableSize();
assertTrue(mss.getHeapSize() > 0); // assert that the memstore is not dropped

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

long storeMemstoreSize = store.getMemStoreSize().getHeapSize();
long regionMemstoreSize = secondaryRegion.getMemStoreDataSize();
MemStoreSize mss = store.getFlushableSize();
long storeSize = store.getSize();
long storeSizeUncompressed = store.getStoreSizeUncompressed();
  assertEquals(expectedStoreFileCount, s.getStorefilesCount());
 MemStoreSize newMss = store.getFlushableSize();
 assertTrue(mss.getHeapSize() > newMss.getHeapSize());

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

MemStoreSize mss = store.getFlushableSize();
assertTrue(mss.getHeapSize() > 0); // assert that the memstore is not dropped

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

MemStoreSize mss = store.getFlushableSize();
if (droppableMemstore) {

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

long storeMemstoreSize = store.getMemStoreSize().getHeapSize();
long regionMemstoreSize = secondaryRegion.getMemStoreDataSize();
MemStoreSize mss = store.getFlushableSize();