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

Store.getStorefiles介绍

暂无

代码示例

代码示例来源：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

for (Store store : stores) {
 String cf = store.getColumnFamilyName();
 Collection<? extends StoreFile> storeFiles = store.getStorefiles(); 
out.write("\n\n       <h3>Column Family: ");
out.print( cf );

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

HStoreFile hsf = ((Collection<HStoreFile>)region.getStore(familyNameBytes).getStorefiles())
  .iterator().next();
long readPt = ((HRegion)region).getReadPoint(IsolationLevel.READ_COMMITTED);

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

for (HStoreFile sf : (Collection<HStoreFile>)region.getStore(familyNameBytes).getStorefiles()) {
 synchronized (sf) {
  if (count < refSFCount) {

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

public static boolean isLocalIndexStoreFilesConsistent(RegionCoprocessorEnvironment environment, Store store) {
  byte[] startKey = environment.getRegion().getRegionInfo().getStartKey();
  byte[] endKey = environment.getRegion().getRegionInfo().getEndKey();
  byte[] indexKeyEmbedded = startKey.length == 0 ? new byte[endKey.length] : startKey;
  for (StoreFile file : store.getStorefiles()) {
    if (file.getFirstKey().isPresent() && file.getFirstKey().get() != null) {
      byte[] fileFirstRowKey = CellUtil.cloneRow(file.getFirstKey().get());
      if ((fileFirstRowKey != null && Bytes.compareTo(fileFirstRowKey, 0,
          indexKeyEmbedded.length, indexKeyEmbedded, 0, indexKeyEmbedded.length) != 0)) {
        return false; }
    }
  }
  return true;
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * @return True if this region has references.
 */
public boolean hasReferences() {
 for (Store store : this.stores.values()) {
  for (StoreFile sf : store.getStorefiles()) {
   // Found a reference, return.
   if (sf.isReference()) return true;
  }
 }
 return false;
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * @return The maximum sequence id in all store files.
 */
long getMaxSequenceId() {
 return StoreFile.getMaxSequenceIdInList(this.getStorefiles());
}

代码示例来源：origin: co.cask.hbase/hbase

/**
 * @return The maximum memstoreTS in all store files.
 */
public long getMaxMemstoreTS() {
 return StoreFile.getMaxMemstoreTSInList(this.getStorefiles());
}

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

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

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

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

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

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

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

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

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

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

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

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

代码示例来源：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: 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: 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: harbby/presto-connectors

private void logRegionFiles() {
 if (LOG.isTraceEnabled()) {
  LOG.trace(getRegionInfo().getEncodedName() + " : Store files for region: ");
  for (Store s : stores.values()) {
   Collection<StoreFile> storeFiles = s.getStorefiles();
   if (storeFiles == null) continue;
   for (StoreFile sf : storeFiles) {
    LOG.trace(getRegionInfo().getEncodedName() + " : " + sf);
   }
  }
 }
}