Package | Description |
---|---|
io.druid.guice | |
io.druid.query | |
io.druid.query.groupby | |
io.druid.query.groupby.epinephelinae | |
io.druid.query.groupby.strategy | |
io.druid.query.topn | |
io.druid.segment.incremental |
Modifier and Type | Method and Description |
---|---|
StupidPool<ByteBuffer> |
DruidProcessingModule.getIntermediateResultsPool(DruidProcessingConfig config) |
Constructor and Description |
---|
GroupByMergedQueryRunner(ExecutorService exec,
com.google.common.base.Supplier<GroupByQueryConfig> configSupplier,
QueryWatcher queryWatcher,
StupidPool<ByteBuffer> bufferPool,
Iterable<QueryRunner<T>> queryables) |
Modifier and Type | Method and Description |
---|---|
static <T> Pair<IncrementalIndex,Accumulator<IncrementalIndex,T>> |
GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query,
GroupByQueryConfig config,
StupidPool<ByteBuffer> bufferPool,
boolean combine) |
static IncrementalIndex |
GroupByQueryHelper.makeIncrementalIndex(GroupByQuery query,
GroupByQueryConfig config,
StupidPool<ByteBuffer> bufferPool,
Sequence<Row> rows,
boolean combine) |
Constructor and Description |
---|
GroupByQueryEngine(com.google.common.base.Supplier<GroupByQueryConfig> config,
StupidPool<ByteBuffer> intermediateResultsBufferPool) |
Modifier and Type | Method and Description |
---|---|
static Sequence<Row> |
GroupByQueryEngineV2.process(GroupByQuery query,
StorageAdapter storageAdapter,
StupidPool<ByteBuffer> intermediateResultsBufferPool,
GroupByQueryConfig config) |
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 |
---|
AggregateTopNMetricFirstAlgorithm(Capabilities capabilities,
TopNQuery query,
StupidPool<ByteBuffer> bufferPool) |
PooledTopNAlgorithm(Capabilities capabilities,
TopNQuery query,
StupidPool<ByteBuffer> bufferPool) |
TopNQueryEngine(StupidPool<ByteBuffer> bufferPool) |
TopNQueryRunnerFactory(StupidPool<ByteBuffer> computationBufferPool,
TopNQueryQueryToolChest toolchest,
QueryWatcher queryWatcher) |
Constructor and Description |
---|
OffheapIncrementalIndex(IncrementalIndexSchema incrementalIndexSchema,
boolean deserializeComplexMetrics,
boolean reportParseExceptions,
boolean sortFacts,
int maxRowCount,
StupidPool<ByteBuffer> bufferPool) |
OffheapIncrementalIndex(long minTimestamp,
Granularity gran,
AggregatorFactory[] metrics,
int maxRowCount,
StupidPool<ByteBuffer> bufferPool) |
OffheapIncrementalIndex(long minTimestamp,
Granularity gran,
boolean rollup,
AggregatorFactory[] metrics,
int maxRowCount,
StupidPool<ByteBuffer> bufferPool) |
Copyright © 2011–2017. All rights reserved.