org.apache.hadoop.hbase.regionserver.Store.getCompactPriority()方法的使用及代码示例

x33g5p2x  于2022-01-30 转载在 其他  
字(1.9k)|赞(0)|评价(0)|浏览(149)

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

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 {

相关文章