Modifier and Type | Field and Description |
---|---|
static QueryWatcher |
QueryBenchmarkUtil.NOOP_QUERYWATCHER |
Constructor and Description |
---|
BrokerServerView(QueryToolChestWarehouse warehouse,
QueryWatcher queryWatcher,
com.fasterxml.jackson.databind.ObjectMapper smileMapper,
com.metamx.http.client.HttpClient httpClient,
FilteredServerInventoryView baseView,
TierSelectorStrategy tierSelectorStrategy,
com.metamx.emitter.service.ServiceEmitter emitter,
BrokerSegmentWatcherConfig segmentWatcherConfig) |
DirectDruidClient(QueryToolChestWarehouse warehouse,
QueryWatcher queryWatcher,
com.fasterxml.jackson.databind.ObjectMapper objectMapper,
com.metamx.http.client.HttpClient httpClient,
String host,
com.metamx.emitter.service.ServiceEmitter emitter) |
Modifier and Type | Class and Description |
---|---|
class |
NoopQueryWatcher |
Constructor and Description |
---|
AsyncQueryRunner(QueryRunner<T> baseRunner,
ExecutorService executor,
QueryWatcher queryWatcher) |
ChainedExecutionQueryRunner(ExecutorService exec,
QueryWatcher queryWatcher,
Iterable<QueryRunner<T>> queryables) |
ChainedExecutionQueryRunner(ExecutorService exec,
QueryWatcher queryWatcher,
QueryRunner<T>... queryables) |
GroupByMergedQueryRunner(ExecutorService exec,
com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
QueryWatcher queryWatcher,
StupidPool<ByteBuffer> bufferPool,
Iterable<QueryRunner<T>> queryables) |
IntervalChunkingQueryRunner(QueryRunner<T> baseRunner,
QueryToolChest<T,Query<T>> toolChest,
ExecutorService executor,
QueryWatcher queryWatcher,
com.metamx.emitter.service.ServiceEmitter emitter) |
IntervalChunkingQueryRunnerDecorator(ExecutorService executor,
QueryWatcher queryWatcher,
com.metamx.emitter.service.ServiceEmitter emitter) |
Constructor and Description |
---|
DataSourceMetadataQueryRunnerFactory(QueryWatcher queryWatcher) |
Constructor and Description |
---|
GroupByMergingQueryRunnerV2(GroupByQueryConfig config,
ExecutorService exec,
QueryWatcher queryWatcher,
Iterable<QueryRunner<Row>> queryables,
int concurrencyHint,
BlockingPool<ByteBuffer> mergeBufferPool,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
String processingTmpDir) |
Constructor and Description |
---|
GroupByStrategyV1(com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
GroupByQueryEngine engine,
QueryWatcher queryWatcher,
StupidPool<ByteBuffer> bufferPool) |
GroupByStrategyV2(DruidProcessingConfig processingConfig,
com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
StupidPool<ByteBuffer> bufferPool,
BlockingPool<ByteBuffer> mergeBufferPool,
com.fasterxml.jackson.databind.ObjectMapper spillMapper,
QueryWatcher queryWatcher) |
Constructor and Description |
---|
SegmentMetadataQueryRunnerFactory(SegmentMetadataQueryQueryToolChest toolChest,
QueryWatcher queryWatcher) |
Constructor and Description |
---|
SearchQueryRunnerFactory(SearchStrategySelector strategySelector,
SearchQueryQueryToolChest toolChest,
QueryWatcher queryWatcher) |
Constructor and Description |
---|
SelectQueryRunnerFactory(SelectQueryQueryToolChest toolChest,
SelectQueryEngine engine,
QueryWatcher queryWatcher) |
Constructor and Description |
---|
TimeBoundaryQueryRunnerFactory(QueryWatcher queryWatcher) |
Constructor and Description |
---|
TimeseriesQueryRunnerFactory(TimeseriesQueryQueryToolChest toolChest,
TimeseriesQueryEngine engine,
QueryWatcher queryWatcher) |
Constructor and Description |
---|
TopNQueryRunnerFactory(StupidPool<ByteBuffer> computationBufferPool,
TopNQueryQueryToolChest toolchest,
QueryWatcher queryWatcher) |
Modifier and Type | Class and Description |
---|---|
class |
QueryManager |
Copyright © 2011–2017. All rights reserved.