io.druid.query.timeboundary

Class TimeBoundaryQueryQueryToolChest

java.lang.Object

io.druid.query.QueryToolChest<Result<TimeBoundaryResultValue>,TimeBoundaryQuery>

io.druid.query.timeboundary.TimeBoundaryQueryQueryToolChest

public class TimeBoundaryQueryQueryToolChest
extends QueryToolChest<Result<TimeBoundaryResultValue>,TimeBoundaryQuery>

Constructor Summary

Constructors

Constructor and Description
TimeBoundaryQueryQueryToolChest()

Method Summary

Methods

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

Methods inherited from class io.druid.query.QueryToolChest

makePostComputeManipulatorFn, postMergeQueryDecoration, preMergeQueryDecoration

Methods inherited from class java.lang.Object

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

Constructor Detail

TimeBoundaryQueryQueryToolChest

public TimeBoundaryQueryQueryToolChest()

Method Detail

filterSegments

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

Overrides:

filterSegments in class QueryToolChest<Result<TimeBoundaryResultValue>,TimeBoundaryQuery>

mergeResults

public QueryRunner<Result<TimeBoundaryResultValue>> mergeResults(QueryRunner<Result<TimeBoundaryResultValue>> runner)

Specified by:

mergeResults in class QueryToolChest<Result<TimeBoundaryResultValue>,TimeBoundaryQuery>

mergeSequences

public com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>> mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>>> seqOfSequences)

Description copied from class: QueryToolChest

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

Specified by:

mergeSequences in class QueryToolChest<Result<TimeBoundaryResultValue>,TimeBoundaryQuery>

Parameters:

seqOfSequences - sequence of sequences to be merged

Returns:

the sequence of merged results

mergeSequencesUnordered

public com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>> mergeSequencesUnordered(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<TimeBoundaryResultValue>>> seqOfSequences)

Specified by:

mergeSequencesUnordered in class QueryToolChest<Result<TimeBoundaryResultValue>,TimeBoundaryQuery>

makeMetricBuilder

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

Specified by:

makeMetricBuilder in class QueryToolChest<Result<TimeBoundaryResultValue>,TimeBoundaryQuery>

makePreComputeManipulatorFn

public com.google.common.base.Function<Result<TimeBoundaryResultValue>,Result<TimeBoundaryResultValue>> makePreComputeManipulatorFn(TimeBoundaryQuery query,
                                                                                                                           MetricManipulationFn fn)

Specified by:

makePreComputeManipulatorFn in class QueryToolChest<Result<TimeBoundaryResultValue>,TimeBoundaryQuery>

getResultTypeReference

public com.fasterxml.jackson.core.type.TypeReference<Result<TimeBoundaryResultValue>> getResultTypeReference()

Specified by:

getResultTypeReference in class QueryToolChest<Result<TimeBoundaryResultValue>,TimeBoundaryQuery>

getCacheStrategy

public CacheStrategy<Result<TimeBoundaryResultValue>,Object,TimeBoundaryQuery> getCacheStrategy(TimeBoundaryQuery query)

Overrides:

getCacheStrategy in class QueryToolChest<Result<TimeBoundaryResultValue>,TimeBoundaryQuery>

getOrdering

public com.google.common.collect.Ordering<Result<TimeBoundaryResultValue>> getOrdering()