本文整理了Java中org.apache.hadoop.hbase.regionserver.Store.getCompactPriority()
方法的一些代码示例,展示了Store.getCompactPriority()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Store.getCompactPriority()
方法的具体详情如下:
包路径:org.apache.hadoop.hbase.regionserver.Store
类名称:Store
方法名:getCompactPriority
暂无
代码示例来源:origin: co.cask.hbase/hbase
public int getCompactPriority() {
return getCompactPriority(NO_PRIORITY);
}
代码示例来源:origin: co.cask.hbase/hbase
/**
* @return The priority that this region should have in the compaction queue
*/
public int getCompactPriority() {
int count = Integer.MAX_VALUE;
for(Store store : stores.values()) {
count = Math.min(count, store.getCompactPriority());
}
return count;
}
代码示例来源:origin: harbby/presto-connectors
/**
* @return The priority that this region should have in the compaction queue
*/
public int getCompactPriority() {
int count = Integer.MAX_VALUE;
for (Store store : stores.values()) {
count = Math.min(count, store.getCompactPriority());
}
return count;
}
代码示例来源:origin: harbby/presto-connectors
public CompactionRunner(Store store, Region region,
CompactionContext compaction, ThreadPoolExecutor parent, User user) {
super();
this.store = store;
this.region = (HRegion)region;
this.compaction = compaction;
this.queuedPriority = (this.compaction == null)
? store.getCompactPriority() : compaction.getRequest().getPriority();
this.parent = parent;
this.user = user;
}
代码示例来源:origin: co.cask.hbase/hbase
int pri = getCompactPriority(priority);
代码示例来源:origin: co.cask.hbase/hbase
server.getMetrics().addCompaction(now - start, this.totalSize);
if (s.getCompactPriority() <= 0) {
server.getCompactSplitThread()
.requestCompaction(r, s, "Recursive enqueue", null);
代码示例来源:origin: harbby/presto-connectors
this.queuedPriority = this.store.getCompactPriority();
if (this.queuedPriority > oldPriority) {
if (completed) {
if (store.getCompactPriority() <= 0) {
requestSystemCompaction(region, store, "Recursive enqueue");
} else {
内容来源于网络,如有侵权,请联系作者删除!