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

Region.getStores介绍

[英]Return the list of Stores managed by this region

Use with caution. Exposed for use of fixup utilities.
[中]返回此区域管理的门店列表
小心使用。暴露在外以供安装工具使用。

代码示例

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

private int getStoreFileCount(Region region) {
 int count = 0;
 for (Store store : region.getStores()) {
  count += store.getStorefilesCount();
 }
 return count;
}

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

@Override
public double getCompactionPressure() {
 double max = 0;
 for (Region region : onlineRegions.values()) {
  for (Store store : region.getStores()) {
   double normCount = store.getCompactionPressure();
   if (normCount > max) {
    max = normCount;
   }
  }
 }
 return max;
}

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

/**
 * Computes total FileSystem size for the given {@link Region}.
 *
 * @param r The region
 * @return The size, in bytes, of the Region.
 */
long computeSize(Region r) {
 long regionSize = 0L;
 for (Store store : r.getStores()) {
  regionSize += store.getHFilesSize();
 }
 if (LOG.isTraceEnabled()) {
  LOG.trace("Size of " + r + " is " + regionSize);
 }
 return regionSize;
}

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

private boolean isTooManyStoreFiles(Region region) {
 // When compaction is disabled, the region is flushable
 if (!region.getTableDescriptor().isCompactionEnabled()) {
  return false;
 }
 for (Store store : region.getStores()) {
  if (store.hasTooManyStoreFiles()) {
   return true;
  }
 }
 return false;
}

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

public CacheEvictionStats clearRegionBlockCache(Region region) {
 long evictedBlocks = 0;
 for(Store store : region.getStores()) {
  for(StoreFile hFile : store.getStorefiles()) {
   evictedBlocks += blockCache.evictBlocksByHfileName(hFile.getPath().getName());
  }
 }
 return CacheEvictionStats.builder()
   .withEvictedBlocks(evictedBlocks)
   .build();
}

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

/**
 * Creates a region with a number of Stores equal to the length of {@code storeSizes}. Each
 * {@link Store} will have a reported size corresponding to the element in {@code storeSizes}.
 *
 * @param storeSizes A list of sizes for each Store.
 * @return A mocked Region.
 */
private Region mockRegionWithSize(Collection<Long> storeSizes) {
 final Region r = mock(Region.class);
 final RegionInfo info = mock(RegionInfo.class);
 when(r.getRegionInfo()).thenReturn(info);
 List<Store> stores = new ArrayList<>();
 when(r.getStores()).thenReturn((List) stores);
 for (Long storeSize : storeSizes) {
  final Store s = mock(Store.class);
  stores.add(s);
  when(s.getHFilesSize()).thenReturn(storeSize);
 }
 return r;
}

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

@Override
public void refreshHFiles(RpcController controller, RefreshHFilesProtos.RefreshHFilesRequest request,
             RpcCallback<RefreshHFilesProtos.RefreshHFilesResponse> done) {
 try {
  for (Store store : env.getRegion().getStores()) {
   LOG.debug("Refreshing HFiles for region: " + store.getRegionInfo().getRegionNameAsString() +
         " and store: " + store.getColumnFamilyName() + "class:" + store.getClass());
   store.refreshStoreFiles();
  }
 } catch (IOException ioe) {
  LOG.error("Exception while trying to refresh store files: ", ioe);
  CoprocessorRpcUtils.setControllerException(controller, ioe);
 }
 done.run(RefreshHFilesProtos.RefreshHFilesResponse.getDefaultInstance());
}

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

private Region mockRegionWithHFileLinks(Collection<Long> storeSizes, Collection<Long> hfileSizes) {
 final Region r = mock(Region.class);
 final RegionInfo info = mock(RegionInfo.class);
 when(r.getRegionInfo()).thenReturn(info);
 List<Store> stores = new ArrayList<>();
 when(r.getStores()).thenReturn((List) stores);
 assertEquals(
   "Logic error, storeSizes and linkSizes must be equal in size", storeSizes.size(),
   hfileSizes.size());
 Iterator<Long> storeSizeIter = storeSizes.iterator();
 Iterator<Long> hfileSizeIter = hfileSizes.iterator();
 while (storeSizeIter.hasNext() && hfileSizeIter.hasNext()) {
  final long storeSize = storeSizeIter.next();
  final long hfileSize = hfileSizeIter.next();
  final Store s = mock(Store.class);
  stores.add(s);
  when(s.getStorefilesSize()).thenReturn(storeSize);
  when(s.getHFilesSize()).thenReturn(hfileSize);
 }
 return r;
}

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

for (Store store : r.getStores()) {

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

localMetricsTableMap.put(tbl, mt);
if (r.getStores() != null) {
 for (Store store : r.getStores()) {
  mt.storeFileCount += store.getStorefilesCount();
  mt.memstoreSize += (store.getMemStoreSize().getDataSize() +

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

out.write("</h1>\n        </div>\n    </div>\n\n");
if(region != null) { //
  List<? extends Store> stores = region.getStores();
  for (Store store : stores) {
   String cf = store.getColumnFamilyName();

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

!scan.getFamilyMap().isEmpty() &&
    MetaDataUtil.isLocalIndexFamily(scan.getFamilyMap().keySet().iterator().next());
for (Store store : region.getStores()) {
  ImmutableBytesPtr cfKey = new ImmutableBytesPtr(store.getColumnFamilyDescriptor().getName());
  boolean isLocalIndexStore = MetaDataUtil.isLocalIndexFamily(cfKey);

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

List<? extends Store> stores = region.getStores();
long summer = 0;
for (Store store : stores) {

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

for (Store s : env.getRegion().getStores()) {
  if (!IndexUtil.isLocalIndexStore(s)) {
    scan.addFamily(s.getColumnFamilyDescriptor().getName());

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

@Override
public double getCompactionPressure() {
 double max = 0;
 for (Region region : onlineRegions.values()) {
  for (Store store : region.getStores()) {
   double normCount = store.getCompactionPressure();
   if (normCount > max) {
    max = normCount;
   }
  }
 }
 return max;
}

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

private boolean isTooManyStoreFiles(Region region) {
 for (Store store : region.getStores()) {
  if (store.hasTooManyStoreFiles()) {
   return true;
  }
 }
 return false;
}

代码示例来源：origin: cdapio/cdap

private long numStoreFilesForRegion(ObserverContext<RegionCoprocessorEnvironment> c) {
 long numStoreFiles = 0;
 for (Store store : c.getEnvironment().getRegion().getStores()) {
  numStoreFiles += store.getStorefiles().size();
 }
 return numStoreFiles;
}

代码示例来源：origin: org.apache.tephra/tephra-hbase-compat-1.1

private long numStoreFilesForRegion(ObserverContext<RegionCoprocessorEnvironment> c) {
 long numStoreFiles = 0;
 for (Store store : c.getEnvironment().getRegion().getStores()) {
  numStoreFiles += store.getStorefiles().size();
 }
 return numStoreFiles;
}

代码示例来源：origin: caskdata/cdap

private long numStoreFilesForRegion(ObserverContext<RegionCoprocessorEnvironment> c) {
 long numStoreFiles = 0;
 for (Store store : c.getEnvironment().getRegion().getStores()) {
  numStoreFiles += store.getStorefiles().size();
 }
 return numStoreFiles;
}

代码示例来源：origin: com.aliyun.hbase/alihbase-examples

@Override
public void refreshHFiles(RpcController controller, RefreshHFilesProtos.RefreshHFilesRequest request,
             RpcCallback<RefreshHFilesProtos.RefreshHFilesResponse> done) {
 try {
  for (Store store : env.getRegion().getStores()) {
   LOG.debug("Refreshing HFiles for region: " + store.getRegionInfo().getRegionNameAsString() +
         " and store: " + store.getColumnFamilyName() + "class:" + store.getClass());
   store.refreshStoreFiles();
  }
 } catch (IOException ioe) {
  LOG.error("Exception while trying to refresh store files: ", ioe);
  CoprocessorRpcUtils.setControllerException(controller, ioe);
 }
 done.run(RefreshHFilesProtos.RefreshHFilesResponse.getDefaultInstance());
}