本文整理了Java中org.apache.hadoop.hbase.regionserver.Store.getStorefilesCount()
方法的一些代码示例,展示了Store.getStorefilesCount()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Store.getStorefilesCount()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.regionserver.Store
类名称:Store
方法名:getStorefilesCount
暂无
代码示例来源:origin: apache/hbase
private int getStoreFileCount(Region region) {
int count = 0;
for (Store store : region.getStores()) {
count += store.getStorefilesCount();
}
return count;
}
代码示例来源:origin: apache/hbase
public int getNumHFilesForRS(final HRegionServer rs, final TableName tableName,
final byte[] family) {
int numHFiles = 0;
for (Region region : rs.getRegions(tableName)) {
numHFiles += region.getStore(family).getStorefilesCount();
}
return numHFiles;
}
代码示例来源:origin: apache/hbase
mt.storeFileCount += store.getStorefilesCount();
mt.memstoreSize += (store.getMemStoreSize().getDataSize() +
store.getMemStoreSize().getHeapSize() + store.getMemStoreSize().getOffHeapSize());
mt.minStoreFileAge = Math.min(mt.minStoreFileAge, store.getMinStoreFileAge().getAsLong());
mt.totalStoreFileAge = (long)store.getAvgStoreFileAge().getAsDouble() *
store.getStorefilesCount();
mt.storeCount += 1;
代码示例来源:origin: apache/hbase
if (region.stores != null) {
for (Store store : region.stores.values()) {
tempNumStoreFiles += store.getStorefilesCount();
tempMemstoreSize += store.getMemStoreSize().getDataSize();
tempStoreFileSize += store.getStorefilesSize();
代码示例来源:origin: apache/hbase
cf1StoreFileCount = region.getStore(FAMILY1).getStorefilesCount();
cf2StoreFileCount = region.getStore(FAMILY2).getStorefilesCount();
cf3StoreFileCount = region.getStore(FAMILY3).getStorefilesCount();
} finally {
TEST_UTIL.shutdownMiniCluster();
cf1StoreFileCount1 = region.getStore(FAMILY1).getStorefilesCount();
cf2StoreFileCount1 = region.getStore(FAMILY2).getStorefilesCount();
cf3StoreFileCount1 = region.getStore(FAMILY3).getStorefilesCount();
} finally {
TEST_UTIL.shutdownMiniCluster();
代码示例来源:origin: apache/hbase
tempNumStores += storeList.size();
for (Store store : storeList) {
tempNumStoreFiles += store.getStorefilesCount();
tempMemstoreSize += store.getMemStoreSize().getDataSize();
tempStoreFileSize += store.getStorefilesSize();
代码示例来源:origin: apache/hbase
public static void compactAndBlockUntilDone(Admin admin, HRegionServer rs, byte[] regionName)
throws IOException, InterruptedException {
log("Compacting region: " + Bytes.toStringBinary(regionName));
admin.majorCompactRegion(regionName);
log("blocking until compaction is complete: " + Bytes.toStringBinary(regionName));
Threads.sleepWithoutInterrupt(500);
outer: for (;;) {
for (Store store : rs.getOnlineRegion(regionName).getStores()) {
if (store.getStorefilesCount() > 1) {
Threads.sleep(50);
continue outer;
}
}
break;
}
}
代码示例来源:origin: apache/hbase
Assert.assertEquals(1, secondaryRegion.getStore(f).getStorefilesCount());
Assert.assertEquals(3, secondaryRegion.getStore(f).getStorefilesCount());
Assert.assertEquals(4, secondaryRegion.getStore(f).getStorefilesCount());
代码示例来源:origin: apache/hbase
assertEquals("Should have no WAL after initial writes", 0,
AbstractFSWALProvider.getNumRolledLogFiles(log));
assertEquals(2, s.getStorefilesCount());
for (int waitTime = 3000; s.getStorefilesCount() > 1 && waitTime > 0; waitTime -= 200) {
Threads.sleepWithoutInterrupt(200);
assertEquals("Compaction didn't happen", 1, s.getStorefilesCount());
代码示例来源:origin: apache/hbase
Assert.assertEquals(3, secondaryRegion.getStore(f).getStorefilesCount());
代码示例来源:origin: co.cask.hbase/hbase
private boolean isTooManyStoreFiles(HRegion region) {
for (Store hstore: region.stores.values()) {
if (hstore.getStorefilesCount() > this.blockingStoreFilesNumber) {
return true;
}
}
return false;
}
代码示例来源: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
stores += r.stores.size();
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
public int getNumHFilesForRS(final HRegionServer rs, final TableName tableName,
final byte[] family) {
int numHFiles = 0;
for (Region region : rs.getRegions(tableName)) {
numHFiles += region.getStore(family).getStorefilesCount();
}
return numHFiles;
}
代码示例来源:origin: co.cask.hbase/hbase
stores += r.stores.size();
for (Store store : r.stores.values()) {
storefiles += store.getStorefilesCount();
storeUncompressedSizeMB += (int) (store.getStoreSizeUncompressed()
/ 1024 / 1024);
代码示例来源:origin: harbby/presto-connectors
this.cellsPerHeartbeatCheck = scanInfo.getCellsPerTimeoutCheck();
if (this.store != null && this.store.getStorefilesCount() > 1) {
RegionServerServices rsService = ((HStore)store).getHRegion().getRegionServerServices();
if (rsService != null && scanInfo.isParallelSeekEnabled()) {
代码示例来源:origin: org.apache.hbase/hbase-server
public static void compactAndBlockUntilDone(Admin admin, HRegionServer rs, byte[] regionName)
throws IOException, InterruptedException {
log("Compacting region: " + Bytes.toStringBinary(regionName));
admin.majorCompactRegion(regionName);
log("blocking until compaction is complete: " + Bytes.toStringBinary(regionName));
Threads.sleepWithoutInterrupt(500);
outer: for (;;) {
for (Store store : rs.getOnlineRegion(regionName).getStores()) {
if (store.getStorefilesCount() > 1) {
Threads.sleep(50);
continue outer;
}
}
break;
}
}
代码示例来源:origin: org.apache.hbase/hbase-server
Assert.assertEquals(1, secondaryRegion.getStore(f).getStorefilesCount());
Assert.assertEquals(3, secondaryRegion.getStore(f).getStorefilesCount());
Assert.assertEquals(4, secondaryRegion.getStore(f).getStorefilesCount());
代码示例来源:origin: org.apache.hbase/hbase-server
Assert.assertEquals(3, secondaryRegion.getStore(f).getStorefilesCount());
代码示例来源:origin: org.apache.hbase/hbase-server
assertEquals("Should have no WAL after initial writes", 0,
AbstractFSWALProvider.getNumRolledLogFiles(log));
assertEquals(2, s.getStorefilesCount());
for (int waitTime = 3000; s.getStorefilesCount() > 1 && waitTime > 0; waitTime -= 200) {
Threads.sleepWithoutInterrupt(200);
assertEquals("Compaction didn't happen", 1, s.getStorefilesCount());
内容来源于网络,如有侵权,请联系作者删除!