io.druid.query

Class QueryToolChest<ResultType,QueryType extends Query<ResultType>>

java.lang.Object

io.druid.query.QueryToolChest<ResultType,QueryType>

Direct Known Subclasses:

GroupByQueryQueryToolChest, SearchQueryQueryToolChest, SegmentMetadataQueryQueryToolChest, SelectQueryQueryToolChest, TimeBoundaryQueryQueryToolChest, TimeseriesQueryQueryToolChest, TopNQueryQueryToolChest

public abstract class QueryToolChest<ResultType,QueryType extends Query<ResultType>>
extends Object

The broker-side (also used by server in some cases) API for a specific Query type. This API is still undergoing evolution and is only semi-stable, so proprietary Query implementations should be ready for the potential maintenance burden when upgrading versions.

Constructor Summary

Constructors

Constructor and Description
QueryToolChest()

Method Summary

Methods

Modifier and Type	Method and Description
<T extends LogicalSegment> List<T>	filterSegments(QueryType query, List<T> segments)
<T> CacheStrategy<ResultType,T,QueryType>	getCacheStrategy(QueryType query)
abstract com.fasterxml.jackson.core.type.TypeReference<ResultType>	getResultTypeReference()
abstract com.metamx.emitter.service.ServiceMetricEvent.Builder	makeMetricBuilder(QueryType query)
com.google.common.base.Function<ResultType,ResultType>	makePostComputeManipulatorFn(QueryType query, MetricManipulationFn fn)
abstract com.google.common.base.Function<ResultType,ResultType>	makePreComputeManipulatorFn(QueryType query, MetricManipulationFn fn)
abstract QueryRunner<ResultType>	mergeResults(QueryRunner<ResultType> runner)
abstract com.metamx.common.guava.Sequence<ResultType>	mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<ResultType>> seqOfSequences) This method doesn't belong here, but it's here for now just to make it work.
abstract com.metamx.common.guava.Sequence<ResultType>	mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<ResultType>> seqOfSequences)
QueryRunner<ResultType>	postMergeQueryDecoration(QueryRunner<ResultType> runner)
QueryRunner<ResultType>	preMergeQueryDecoration(QueryRunner<ResultType> runner)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

QueryToolChest

public QueryToolChest()

Method Detail

mergeResults

public abstract QueryRunner<ResultType> mergeResults(QueryRunner<ResultType> runner)

mergeSequences

public abstract com.metamx.common.guava.Sequence<ResultType> mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<ResultType>> seqOfSequences)

This method doesn't belong here, but it's here for now just to make it work.

Parameters:

seqOfSequences - sequence of sequences to be merged

Returns:

the sequence of merged results

mergeSequencesUnordered

public abstract com.metamx.common.guava.Sequence<ResultType> mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<ResultType>> seqOfSequences)

makeMetricBuilder

public abstract com.metamx.emitter.service.ServiceMetricEvent.Builder makeMetricBuilder(QueryType query)

makePreComputeManipulatorFn

public abstract com.google.common.base.Function<ResultType,ResultType> makePreComputeManipulatorFn(QueryType query,
                                                                                 MetricManipulationFn fn)

makePostComputeManipulatorFn

public com.google.common.base.Function<ResultType,ResultType> makePostComputeManipulatorFn(QueryType query,
                                                                                  MetricManipulationFn fn)

getResultTypeReference

public abstract com.fasterxml.jackson.core.type.TypeReference<ResultType> getResultTypeReference()

getCacheStrategy

public <T> CacheStrategy<ResultType,T,QueryType> getCacheStrategy(QueryType query)

preMergeQueryDecoration

public QueryRunner<ResultType> preMergeQueryDecoration(QueryRunner<ResultType> runner)

postMergeQueryDecoration

public QueryRunner<ResultType> postMergeQueryDecoration(QueryRunner<ResultType> runner)

filterSegments

public <T extends LogicalSegment> List<T> filterSegments(QueryType query,
                                                List<T> segments)