本文整理了Java中org.apache.hadoop.hbase.regionserver.Store.getMemStoreSize()
方法的一些代码示例,展示了Store.getMemStoreSize()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Store.getMemStoreSize()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.regionserver.Store
类名称: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();
内容来源于网络,如有侵权,请联系作者删除!