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

QueryRunner介绍

暂无

代码示例

代码示例来源：origin: apache/incubator-druid

@Override
 public Sequence<T> apply(final QueryRunner<T> input)
 {
  return input.run(queryPlus, responseContext);
 }
}

代码示例来源：origin: apache/incubator-druid

@Override
 public Sequence<T> call()
 {
  //Note: this is assumed that baseRunner does most of the work eagerly on call to the
  //run() method and resulting sequence accumulate/yield is fast.
  return baseRunner.run(threadSafeQueryPlus, responseContext);
 }
}

代码示例来源：origin: apache/incubator-druid

@Override
public Sequence<T> run(QueryPlus<T> queryPlus, Map<String, Object> responseContext)
{
 return runner.run(queryPlus, responseContext);
}

代码示例来源：origin: apache/incubator-druid

@Override
 public <T> QueryRunner<T> decorate(final QueryRunner<T> delegate, QueryToolChest<T, ? extends Query<T>> toolChest)
 {
  return (queryPlus, responseContext) -> delegate.run(queryPlus, responseContext);
 }
};

代码示例来源：origin: apache/incubator-druid

@Override
 public Sequence<T> run(final QueryPlus<T> input, final Map<String, Object> responseContext)
 {
  return base.run(
    input.optimizeForSegment(optimizationContext),
    responseContext
  );
 }
}

代码示例来源：origin: apache/incubator-druid

@Override
 public Sequence<T> run(QueryPlus<T> queryPlus, Map<String, Object> responseContext)
 {
  return Sequences.withBaggage(runner.run(queryPlus, responseContext), closeable);
 }
};

代码示例来源：origin: apache/incubator-druid

@Override
 public Sequence<T> apply(Query query)
 {
  return runner.run(
    queryPlus.withQuery(query),
    responseContext
  );
 }
}

代码示例来源：origin: apache/incubator-druid

@Override
 public Sequence<T> apply(DataSource singleSource)
 {
  return baseRunner.run(
    queryPlus.withQuery(query.withDataSource(singleSource)),
    responseContext
  );
 }
}

代码示例来源：origin: apache/incubator-druid

@SuppressWarnings("unchecked")
private Sequence<T> getSimpleServerResults(
  final QueryRunner serverRunner,
  final MultipleSpecificSegmentSpec segmentsOfServerSpec,
  long maxQueuedBytesPerServer
)
{
 return serverRunner.run(
   queryPlus.withQuerySegmentSpec(segmentsOfServerSpec).withMaxQueuedBytes(maxQueuedBytesPerServer),
   responseContext
 );
}

代码示例来源：origin: apache/incubator-druid

@Override
 public Sequence<Result<TopNResultValue>> run(
   QueryPlus<Result<TopNResultValue>> queryPlus,
   Map<String, Object> responseContext
 )
 {
  this.query = (TopNQuery) queryPlus.getQuery();
  return runner.run(queryPlus, responseContext);
 }
}

代码示例来源：origin: apache/incubator-druid

@Override
 public Sequence<Row> run(QueryPlus<Row> queryPlus, Map<String, Object> responseContext)
 {
  QueryRunner<Row> rowQueryRunner = strategySelector.strategize((GroupByQuery) queryPlus.getQuery()).mergeRunners(
    queryExecutor,
    queryRunners
  );
  return rowQueryRunner.run(queryPlus, responseContext);
 }
};

代码示例来源：origin: apache/incubator-druid

@Override
public Sequence<T> run(QueryPlus<T> queryPlus, Map<String, Object> responseContext)
{
 if (QueryContexts.isBySegment(queryPlus.getQuery())) {
  return baseRunner.run(queryPlus, responseContext);
 }
 return doRun(baseRunner, queryPlus, responseContext);
}

代码示例来源：origin: apache/incubator-druid

@Override
 public Sequence<T> run(QueryPlus<T> queryPlus, Map<String, Object> responseContext)
 {
  return new BlockingSequence<>(runner.run(queryPlus, responseContext), waitLatch, waitYieldLatch, notifyLatch);
 }
}

代码示例来源：origin: apache/incubator-druid

@Override
public Sequence<T> doRun(QueryRunner<T> baseRunner, QueryPlus<T> queryPlus, Map<String, Object> context)
{
 Query<T> query = queryPlus.getQuery();
 return CombiningSequence.create(baseRunner.run(queryPlus, context), makeOrdering(query), createMergeFn(query));
}

代码示例来源：origin: apache/incubator-druid

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<T, Query<T>> factory = conglomerate.findFactory(query);
 final QueryRunner<T> runner = factory.createRunner(new QueryableIndexSegment(index, SegmentId.dummy("segment")));
 return factory
   .getToolchest()
   .mergeResults(factory.mergeRunners(Execs.directExecutor(), ImmutableList.of(runner)))
   .run(QueryPlus.wrap(query), new HashMap<>());
}

代码示例来源：origin: apache/incubator-druid

private static <T> List<T> runQuery(QueryRunnerFactory factory, QueryRunner runner, Query<T> query)
{
 QueryToolChest toolChest = factory.getToolchest();
 QueryRunner<T> theRunner = new FinalizeResultsQueryRunner<>(
   toolChest.mergeResults(toolChest.preMergeQueryDecoration(runner)),
   toolChest
 );
 Sequence<T> queryResult = theRunner.run(QueryPlus.wrap(query), new HashMap<>());
 return queryResult.toList();
}

代码示例来源：origin: apache/incubator-druid

private static <T> List<T> runQuery(QueryRunnerFactory factory, QueryRunner runner, Query<T> query)
{
 QueryToolChest toolChest = factory.getToolchest();
 QueryRunner<T> theRunner = new FinalizeResultsQueryRunner<>(
   toolChest.mergeResults(toolChest.preMergeQueryDecoration(runner)),
   toolChest
 );
 Sequence<T> queryResult = theRunner.run(QueryPlus.wrap(query), new HashMap<>());
 return queryResult.toList();
}

代码示例来源：origin: apache/incubator-druid

private static <T> List<T> runQuery(QueryRunnerFactory factory, QueryRunner runner, Query<T> query)
{
 QueryToolChest toolChest = factory.getToolchest();
 QueryRunner<T> theRunner = new FinalizeResultsQueryRunner<>(
   toolChest.mergeResults(toolChest.preMergeQueryDecoration(runner)),
   toolChest
 );
 Sequence<T> queryResult = theRunner.run(QueryPlus.wrap(query), new HashMap<>());
 return queryResult.toList();
}

代码示例来源：origin: apache/incubator-druid

private static <T> List<T> runQuery(QueryRunnerFactory factory, QueryRunner runner, Query<T> query)
{
 QueryToolChest toolChest = factory.getToolchest();
 QueryRunner<T> theRunner = new FinalizeResultsQueryRunner<>(
   toolChest.mergeResults(toolChest.preMergeQueryDecoration(runner)),
   toolChest
 );
 Sequence<T> queryResult = theRunner.run(QueryPlus.wrap(query), new HashMap<>());
 return queryResult.toList();
}

代码示例来源：origin: apache/incubator-druid

private static <T> List<T> runQuery(QueryRunnerFactory factory, QueryRunner runner, Query<T> query)
{
 QueryToolChest toolChest = factory.getToolchest();
 QueryRunner<T> theRunner = new FinalizeResultsQueryRunner<>(
   toolChest.mergeResults(toolChest.preMergeQueryDecoration(runner)),
   toolChest
 );
 Sequence<T> queryResult = theRunner.run(QueryPlus.wrap(query), new HashMap<>());
 return queryResult.toList();
}