io.druid.query.datasourcemetadata

Class DataSourceQueryQueryToolChest

java.lang.Object

io.druid.query.QueryToolChest<Result<DataSourceMetadataResultValue>,DataSourceMetadataQuery>

io.druid.query.datasourcemetadata.DataSourceQueryQueryToolChest

public class DataSourceQueryQueryToolChest
extends QueryToolChest<Result<DataSourceMetadataResultValue>,DataSourceMetadataQuery>

Constructor Summary

Constructors

Constructor and Description
DataSourceQueryQueryToolChest()

Method Summary

Methods

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

DataSourceQueryQueryToolChest

public DataSourceQueryQueryToolChest()

Method Detail

filterSegments

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

Overrides:

filterSegments in class QueryToolChest<Result<DataSourceMetadataResultValue>,DataSourceMetadataQuery>

mergeResults

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

Specified by:

mergeResults in class QueryToolChest<Result<DataSourceMetadataResultValue>,DataSourceMetadataQuery>

mergeSequences

public com.metamx.common.guava.Sequence<Result<DataSourceMetadataResultValue>> mergeSequences(com.metamx.common.guava.Sequence<com.metamx.common.guava.Sequence<Result<DataSourceMetadataResultValue>>> 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<DataSourceMetadataResultValue>,DataSourceMetadataQuery>

Parameters:

seqOfSequences - sequence of sequences to be merged

Returns:

the sequence of merged results

mergeSequencesUnordered

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

Specified by:

mergeSequencesUnordered in class QueryToolChest<Result<DataSourceMetadataResultValue>,DataSourceMetadataQuery>

makeMetricBuilder

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

Specified by:

makeMetricBuilder in class QueryToolChest<Result<DataSourceMetadataResultValue>,DataSourceMetadataQuery>

makePreComputeManipulatorFn

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

Specified by:

makePreComputeManipulatorFn in class QueryToolChest<Result<DataSourceMetadataResultValue>,DataSourceMetadataQuery>

getResultTypeReference

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

Specified by:

getResultTypeReference in class QueryToolChest<Result<DataSourceMetadataResultValue>,DataSourceMetadataQuery>

getCacheStrategy

public CacheStrategy getCacheStrategy(DataSourceMetadataQuery query)

Overrides:

getCacheStrategy in class QueryToolChest<Result<DataSourceMetadataResultValue>,DataSourceMetadataQuery>

getOrdering

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