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

HStore.getCompactPriority介绍

暂无

代码示例

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

public HStore createStoreMock(int priority, String name) throws Exception {
  // Override the mock to always return the specified priority.
  HStore s = super.createStoreMock(name);
  when(s.getCompactPriority()).thenReturn(priority);
  return s;
 }
}

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

public CompactionRunner(HStore store, HRegion region, CompactionContext compaction,
  CompactionLifeCycleTracker tracker, CompactionCompleteTracker completeTracker,
  ThreadPoolExecutor parent, User user) {
 this.store = store;
 this.region = region;
 this.compaction = compaction;
 this.tracker = tracker;
 this.completeTracker = completeTracker;
 this.queuedPriority =
   compaction != null ? compaction.getRequest().getPriority() : store.getCompactPriority();
 this.parent = parent;
 this.user = user;
 this.time = EnvironmentEdgeManager.currentTime();
}

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

public HStore createStoreMock(String name) throws Exception {
  HStore store = mock(HStore.class, name);
  when(store.requestCompaction(anyInt(), any(), any())).then(inv -> selectCompaction());
  when(store.getCompactPriority()).then(inv -> getPriority());
  doAnswer(new CancelAnswer()).when(store).cancelRequestedCompaction(any());
  return store;
 }
}

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

this.queuedPriority = this.store.getCompactPriority();
if (this.queuedPriority > oldPriority) {
if (completed) {
 if (store.getCompactPriority() <= 0) {
  requestSystemCompaction(region, store, "Recursive enqueue");
 } else {

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

request.setPriority((priority != Store.NO_PRIORITY) ? priority : getCompactPriority());
request.setDescription(getRegionInfo().getRegionNameAsString(), getColumnFamilyName());
request.setTracker(tracker);

代码示例来源：origin: org.apache.hbase/hbase-server

public HStore createStoreMock(int priority, String name) throws Exception {
  // Override the mock to always return the specified priority.
  HStore s = super.createStoreMock(name);
  when(s.getCompactPriority()).thenReturn(priority);
  return s;
 }
}

代码示例来源：origin: org.apache.hbase/hbase-server

public HStore createStoreMock(String name) throws Exception {
  HStore store = mock(HStore.class, name);
  when(store.requestCompaction(anyInt(), any(), any())).then(inv -> selectCompaction());
  when(store.getCompactPriority()).then(inv -> getPriority());
  doAnswer(new CancelAnswer()).when(store).cancelRequestedCompaction(any());
  return store;
 }
}

代码示例来源：origin: harbby/presto-connectors

request.setPriority((priority != Store.NO_PRIORITY) ? priority : getCompactPriority());
request.setDescription(getRegionInfo().getRegionNameAsString(), getColumnFamilyName());