public class CPUTimeMetricQueryRunner<T> extends Object implements QueryRunner<T>
Modifier and Type | Method and Description |
---|---|
Sequence<T> |
run(QueryPlus<T> queryPlus,
Map<String,Object> responseContext)
Runs the given query and returns results in a time-ordered sequence.
|
static <T> QueryRunner<T> |
safeBuild(QueryRunner<T> delegate,
QueryToolChest<T,? extends Query<T>> queryToolChest,
ServiceEmitter emitter,
AtomicLong accumulator,
boolean report) |
public Sequence<T> run(QueryPlus<T> queryPlus, Map<String,Object> responseContext)
QueryRunner
run
in interface QueryRunner<T>
public static <T> QueryRunner<T> safeBuild(QueryRunner<T> delegate, QueryToolChest<T,? extends Query<T>> queryToolChest, ServiceEmitter emitter, AtomicLong accumulator, boolean report)
Copyright © 2011–2018. All rights reserved.