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