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

Store.throttleCompaction介绍

暂无

代码示例

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

@Override
 public Writer createWriter() throws IOException {
  return store.createWriterInTmp(
    fd.maxKeyCount, compression, true, needMvcc, fd.maxTagsLength > 0,
    store.throttleCompaction(request.getSize()));
 }
};

代码示例来源：origin: co.cask.hbase/hbase

@Override
public synchronized CompactionRequest requestCompaction(final HRegion r, final Store s,
  final String why, int priority, CompactionRequest request) throws IOException {
 if (this.server.isStopped()) {
  return null;
 }
 CompactionRequest cr = s.requestCompaction(priority, request);
 if (cr != null) {
  cr.setServer(server);
  if (priority != Store.NO_PRIORITY) {
   cr.setPriority(priority);
  }
  ThreadPoolExecutor pool = s.throttleCompaction(cr.getSize())
    ? largeCompactions : smallCompactions;
  pool.execute(cr);
  if (LOG.isDebugEnabled()) {
   String type = (pool == smallCompactions) ? "Small " : "Large ";
   LOG.debug(type + "Compaction requested: " + cr
     + (why != null && !why.isEmpty() ? "; Because: " + why : "")
     + "; " + this);
  }
 } else {
  if(LOG.isDebugEnabled()) {
   LOG.debug("Not compacting " + r.getRegionNameAsString() + 
     " because compaction request was cancelled");
  }
 }
 return cr;
}

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

ThreadPoolExecutor pool = (selectNow && s.throttleCompaction(compaction.getRequest().getSize()))
 ? longCompactions : shortCompactions;
pool.execute(new CompactionRunner(s, r, compaction, pool, user));

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

store.throttleCompaction(request.getSize()));
} else {
 readersToClose = Collections.emptyList();
 scanners = createFileScanners(request.getFiles(), smallestReadPoint,
   store.throttleCompaction(request.getSize()));
   fd.maxMVCCReadpoint > 0, fd.maxTagsLength > 0, store.throttleCompaction(request.getSize()));

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

smallestReadPoint, store.throttleCompaction(request.getSize()));

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

ThreadPoolExecutor pool = store.throttleCompaction(
  compaction.getRequest().getSize()) ? longCompactions : shortCompactions;