本文整理了Java中org.apache.hadoop.hbase.regionserver.Store.hasReferences()
方法的一些代码示例,展示了Store.hasReferences()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Store.hasReferences()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.regionserver.Store
类名称:Store
方法名:hasReferences
暂无
代码示例来源:origin: apache/phoenix
@Override
public InternalScanner preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
InternalScanner s, ScanType scanType, CompactionLifeCycleTracker tracker,
CompactionRequest request) throws IOException {
if (!IndexUtil.isLocalIndexStore(store)) { return s; }
if (!store.hasReferences()) {
InternalScanner repairScanner = null;
if (request.isMajor() && (!RepairUtil.isLocalIndexStoreFilesConsistent(c.getEnvironment(), store))) {
LOG.info("we have found inconsistent data for local index for region:"
+ c.getEnvironment().getRegion().getRegionInfo());
if (c.getEnvironment().getConfiguration().getBoolean(LOCAL_INDEX_AUTOMATIC_REPAIR, true)) {
LOG.info("Starting automatic repair of local Index for region:"
+ c.getEnvironment().getRegion().getRegionInfo());
repairScanner = getRepairScanner(c.getEnvironment(), store);
}
}
if (repairScanner != null) {
if (s!=null) {
s.close();
}
return repairScanner;
} else {
return s;
}
}
return s;
}
代码示例来源:origin: co.cask.hbase/hbase
boolean hasReferences() {
return hasReferences(this.storefiles);
}
代码示例来源:origin: harbby/presto-connectors
/**
* @return True if this region has references.
*/
public boolean hasReferences() {
for (Store store : this.stores.values()) {
if (store.hasReferences()) return true;
}
return false;
}
代码示例来源:origin: org.apache.phoenix/phoenix-core
private boolean checkForReferenceFiles() {
if(!ScanUtil.isLocalIndex(scan)) return false;
for (byte[] family : scan.getFamilies()) {
if (getRegion().getStore(family).hasReferences()) {
return true;
}
}
return false;
}
代码示例来源:origin: org.apache.phoenix/phoenix-core
@Override
public InternalScanner preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
InternalScanner s, ScanType scanType, CompactionLifeCycleTracker tracker,
CompactionRequest request) throws IOException {
if (!IndexUtil.isLocalIndexStore(store)) { return s; }
if (!store.hasReferences()) {
InternalScanner repairScanner = null;
if (request.isMajor() && (!RepairUtil.isLocalIndexStoreFilesConsistent(c.getEnvironment(), store))) {
LOG.info("we have found inconsistent data for local index for region:"
+ c.getEnvironment().getRegion().getRegionInfo());
if (c.getEnvironment().getConfiguration().getBoolean(LOCAL_INDEX_AUTOMATIC_REPAIR, true)) {
LOG.info("Starting automatic repair of local Index for region:"
+ c.getEnvironment().getRegion().getRegionInfo());
repairScanner = getRepairScanner(c.getEnvironment(), store);
}
}
if (repairScanner != null) {
if (s!=null) {
s.close();
}
return repairScanner;
} else {
return s;
}
}
return s;
}
代码示例来源:origin: com.aliyun.phoenix/ali-phoenix-core
@Override
public InternalScanner preCompact(ObserverContext<RegionCoprocessorEnvironment> c, Store store,
InternalScanner s, ScanType scanType, CompactionLifeCycleTracker tracker,
CompactionRequest request) throws IOException {
if (!IndexUtil.isLocalIndexStore(store)) { return s; }
if (!store.hasReferences()) {
InternalScanner repairScanner = null;
if (request.isMajor() && (!RepairUtil.isLocalIndexStoreFilesConsistent(c.getEnvironment(), store))) {
LOG.info("we have found inconsistent data for local index for region:"
+ c.getEnvironment().getRegion().getRegionInfo());
if (c.getEnvironment().getConfiguration().getBoolean(LOCAL_INDEX_AUTOMATIC_REPAIR, true)) {
LOG.info("Starting automatic repair of local Index for region:"
+ c.getEnvironment().getRegion().getRegionInfo());
repairScanner = getRepairScanner(c.getEnvironment(), store);
}
}
if (repairScanner != null) {
if (s!=null) {
s.close();
}
return repairScanner;
} else {
return s;
}
}
return s;
}
代码示例来源:origin: co.cask.hbase/hbase
!hasReferences(compactSelection.getFilesToCompact())) {
代码示例来源:origin: co.cask.hbase/hbase
if (s.hasReferences() || s.needsCompaction()) {
getCompactionRequester().requestCompaction(r, s, "Opening Region", null);
代码示例来源:origin: harbby/presto-connectors
if (s.hasReferences() || s.needsCompaction()) {
this.compactSplitThread.requestSystemCompaction(r, s, "Opening Region");
内容来源于网络,如有侵权,请联系作者删除!