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

HStore.cancelRequestedCompaction介绍

暂无

代码示例

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

@Override
 public void rejectedExecution(Runnable runnable, ThreadPoolExecutor pool) {
  if (runnable instanceof CompactionRunner) {
   CompactionRunner runner = (CompactionRunner) runnable;
   LOG.debug("Compaction Rejected: " + runner);
   if (runner.compaction != null) {
    runner.store.cancelRequestedCompaction(runner.compaction);
   }
  }
 }
}

代码示例来源：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

if (this.closing.get() || this.closed.get()) {
 LOG.debug("Skipping compaction on " + this + " because closing/closed");
 store.cancelRequestedCompaction(compaction);
 return false;
   + " because this cluster is transiting sync replication state"
   + " from STANDBY to DOWNGRADE_ACTIVE");
 store.cancelRequestedCompaction(compaction);
 return false;
 return true;
} finally {
 if (requestNeedsCancellation) store.cancelRequestedCompaction(compaction);
 if (status != null) {
  LOG.debug("Compaction status journal:\n\t" + status.prettyPrintJournal());

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

this.store.cancelRequestedCompaction(c);
this.parent = pool;
this.parent.execute(this);

代码示例来源：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;
 }
}