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

QueryManagerConfig.getMaxQueuedQueries介绍

暂无

代码示例

代码示例来源：origin: prestodb/presto

@Inject
public LegacyResourceGroupConfigurationManager(QueryManagerConfig config)
{
  hardConcurrencyLimit = config.getMaxConcurrentQueries();
  maxQueued = config.getMaxQueuedQueries();
}

代码示例来源：origin: uk.co.nichesolutions.presto/presto-main

@Inject
public SqlQueryQueueManager(QueryManagerConfig config, ObjectMapper mapper, MBeanExporter mbeanExporter)
{
  requireNonNull(config, "config is null");
  this.mbeanExporter = requireNonNull(mbeanExporter, "mbeanExporter is null");
  ImmutableList.Builder<QueryQueueRule> rules = ImmutableList.builder();
  if (config.getQueueConfigFile() == null) {
    QueryQueueDefinition global = new QueryQueueDefinition("global", config.getMaxConcurrentQueries(), config.getMaxQueuedQueries());
    rules.add(new QueryQueueRule(null, null, ImmutableMap.of(), ImmutableList.of(global)));
  }
  else {
    File file = new File(config.getQueueConfigFile());
    ManagerSpec managerSpec;
    try {
      managerSpec = mapper.readValue(file, ManagerSpec.class);
    }
    catch (IOException e) {
      throw Throwables.propagate(e);
    }
    Map<String, QueryQueueDefinition> definitions = new HashMap<>();
    for (Map.Entry<String, QueueSpec> queue : managerSpec.getQueues().entrySet()) {
      definitions.put(queue.getKey(), new QueryQueueDefinition(queue.getKey(), queue.getValue().getMaxConcurrent(), queue.getValue().getMaxQueued()));
    }
    for (RuleSpec rule : managerSpec.getRules()) {
      rules.add(QueryQueueRule.createRule(rule.getUserRegex(), rule.getSourceRegex(), rule.getSessionPropertyRegexes(), rule.getQueues(), definitions));
    }
  }
  this.rules = rules.build();
  checkIsDAG(this.rules);
}