static <T> com.metamx.common.Pair<IncrementalIndex,com.metamx.common.guava.Accumulator<IncrementalIndex,T>> |
GroupByQueryHelper.createIndexAccumulatorPair(GroupByQuery query,
GroupByQueryConfig config,
StupidPool<ByteBuffer> bufferPool) |
static Collection<DimensionSpec> |
GroupByQueryQueryToolChest.extractionsToRewrite(GroupByQuery query)
This function checks the query for dimensions which can be optimized by applying the dimension extraction
as the final step of the query instead of on every event.
|
CacheStrategy<io.druid.data.input.Row,Object,GroupByQuery> |
GroupByQueryQueryToolChest.getCacheStrategy(GroupByQuery query) |
com.metamx.emitter.service.ServiceMetricEvent.Builder |
GroupByQueryQueryToolChest.makeMetricBuilder(GroupByQuery query) |
com.google.common.base.Function<io.druid.data.input.Row,io.druid.data.input.Row> |
GroupByQueryQueryToolChest.makePostComputeManipulatorFn(GroupByQuery query,
MetricManipulationFn fn) |
com.google.common.base.Function<io.druid.data.input.Row,io.druid.data.input.Row> |
GroupByQueryQueryToolChest.makePreComputeManipulatorFn(GroupByQuery query,
MetricManipulationFn fn) |
com.metamx.common.guava.Sequence<io.druid.data.input.Row> |
GroupByQueryEngine.process(GroupByQuery query,
StorageAdapter storageAdapter) |