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

QueryRunner.run介绍

[英]Runs the given query and returns results in a time-ordered sequence.
[中]运行给定的查询并按时间顺序返回结果。

代码示例

代码示例来源：origin: io.druid/druid-server

@Override
public Sequence run(QueryPlus queryPlus, Map responseContext)
{
 return baseRunner.run(
   QueryPlus.wrap((Query) withTimeoutAndMaxScatterGatherBytes(
     queryPlus.getQuery(),
     serverConfig
   )),
   responseContext
 );
}

代码示例来源：origin: io.druid/druid-processing

);
return Sequences.map(
  baseRunner.run(
    queryPlus.withQuerySegmentSpec(new MultipleIntervalSegmentSpec(Arrays.asList(modifiedInterval))),
    responseContext
  ),

代码示例来源：origin: io.druid/druid-services

private static <T> Sequence<T> executeQuery(final Injector injector, final QueryableIndex index, final Query<T> query)
{
 final QueryRunnerFactoryConglomerate conglomerate = injector.getInstance(QueryRunnerFactoryConglomerate.class);
 final QueryRunnerFactory factory = conglomerate.findFactory(query);
 final QueryRunner<T> runner = factory.createRunner(new QueryableIndexSegment("segment", index));
 final Sequence results = factory.getToolchest().mergeResults(
   factory.mergeRunners(MoreExecutors.sameThreadExecutor(), ImmutableList.<QueryRunner>of(runner))
 ).run(QueryPlus.wrap(query), Maps.<String, Object>newHashMap());
 return (Sequence<T>) results;
}

代码示例来源：origin: io.druid/druid-processing

configSupplier.get(),
bufferPool,
baseRunner.run(
  QueryPlus.wrap(
    new GroupByQuery.Builder(query)