public class TopNQueryQueryToolChest extends QueryToolChest<Result<TopNResultValue>,TopNQuery>
Constructor and Description |
---|
TopNQueryQueryToolChest(TopNQueryConfig config,
IntervalChunkingQueryRunnerDecorator intervalChunkingQueryRunnerDecorator) |
TopNQueryQueryToolChest(TopNQueryConfig config,
IntervalChunkingQueryRunnerDecorator intervalChunkingQueryRunnerDecorator,
TopNQueryMetricsFactory queryMetricsFactory) |
Modifier and Type | Method and Description |
---|---|
protected static String[] |
extractFactoryName(List<AggregatorFactory> aggregatorFactories) |
CacheStrategy<Result<TopNResultValue>,Object,TopNQuery> |
getCacheStrategy(TopNQuery query)
Returns a CacheStrategy to be used to load data into the cache and remove it from the cache.
|
com.fasterxml.jackson.core.type.TypeReference<Result<TopNResultValue>> |
getResultTypeReference()
Returns a TypeReference object that is just passed through to Jackson in order to deserialize
the results of this type of query.
|
TopNQueryMetrics |
makeMetrics(TopNQuery query)
Creates a
QueryMetrics object that is used to generate metrics for this specific query type. |
com.google.common.base.Function<Result<TopNResultValue>,Result<TopNResultValue>> |
makePostComputeManipulatorFn(TopNQuery query,
MetricManipulationFn fn)
Generally speaking this is the exact same thing as makePreComputeManipulatorFn.
|
com.google.common.base.Function<Result<TopNResultValue>,Result<TopNResultValue>> |
makePreComputeManipulatorFn(TopNQuery query,
MetricManipulationFn fn)
Creates a Function that can take in a ResultType and return a new ResultType having applied
the MetricManipulatorFn to each of the metrics.
|
QueryRunner<Result<TopNResultValue>> |
mergeResults(QueryRunner<Result<TopNResultValue>> runner)
This method wraps a QueryRunner.
|
QueryRunner<Result<TopNResultValue>> |
postMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner)
Wraps a QueryRunner.
|
QueryRunner<Result<TopNResultValue>> |
preMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner)
Wraps a QueryRunner.
|
filterSegments
public TopNQueryQueryToolChest(TopNQueryConfig config, IntervalChunkingQueryRunnerDecorator intervalChunkingQueryRunnerDecorator)
@Inject public TopNQueryQueryToolChest(TopNQueryConfig config, IntervalChunkingQueryRunnerDecorator intervalChunkingQueryRunnerDecorator, TopNQueryMetricsFactory queryMetricsFactory)
protected static String[] extractFactoryName(List<AggregatorFactory> aggregatorFactories)
public QueryRunner<Result<TopNResultValue>> mergeResults(QueryRunner<Result<TopNResultValue>> runner)
QueryToolChest
mergeResults
in class QueryToolChest<Result<TopNResultValue>,TopNQuery>
runner
- A QueryRunner that provides a series of ResultType objects in time order (ascending or descending)public TopNQueryMetrics makeMetrics(TopNQuery query)
QueryToolChest
QueryMetrics
object that is used to generate metrics for this specific query type. This exists
to allow for query-specific dimensions and metrics. That is, the ToolChest is expected to set some
meaningful dimensions for metrics given this query type. Examples might be the topN threshold for
a TopN query or the number of dimensions included for a groupBy query.
QueryToolChests for query types in core (druid-processing) and public extensions (belonging to the Druid source
tree) should use delegate this method to GenericQueryMetricsFactory.makeMetrics(Query)
on an injected
instance of GenericQueryMetricsFactory
, as long as they don't need to emit custom dimensions and/or
metrics.
If some custom dimensions and/or metrics should be emitted for a query type, a plan described in
"Making subinterfaces of QueryMetrics" section in QueryMetrics
's class-level Javadocs should be followed.
One way or another, this method should ensure that QueryMetrics.query(Query)
is called with the given
query passed on the created QueryMetrics object before returning.
makeMetrics
in class QueryToolChest<Result<TopNResultValue>,TopNQuery>
query
- The query that is being processedpublic com.google.common.base.Function<Result<TopNResultValue>,Result<TopNResultValue>> makePreComputeManipulatorFn(TopNQuery query, MetricManipulationFn fn)
QueryToolChest
This exists because the QueryToolChest is the only thing that understands the internal serialization format of ResultType, so it's primary responsibility is to "decompose" that structure and apply the given function to all metrics.
This function is called very early in the processing pipeline on the Broker.
makePreComputeManipulatorFn
in class QueryToolChest<Result<TopNResultValue>,TopNQuery>
query
- The Query that is currently being processedfn
- The function that should be applied to all metrics in the resultspublic com.google.common.base.Function<Result<TopNResultValue>,Result<TopNResultValue>> makePostComputeManipulatorFn(TopNQuery query, MetricManipulationFn fn)
QueryToolChest
This should never actually be overridden and it should be removed as quickly as possible.
makePostComputeManipulatorFn
in class QueryToolChest<Result<TopNResultValue>,TopNQuery>
query
- The Query that is currently being processedfn
- The function that should be applied to all metrics in the resultspublic com.fasterxml.jackson.core.type.TypeReference<Result<TopNResultValue>> getResultTypeReference()
QueryToolChest
getResultTypeReference
in class QueryToolChest<Result<TopNResultValue>,TopNQuery>
public CacheStrategy<Result<TopNResultValue>,Object,TopNQuery> getCacheStrategy(TopNQuery query)
QueryToolChest
This is optional. If it returns null, caching is effectively disabled for the query.
getCacheStrategy
in class QueryToolChest<Result<TopNResultValue>,TopNQuery>
query
- The query whose results might be cachedpublic QueryRunner<Result<TopNResultValue>> preMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner)
QueryToolChest
In fact, the return value of this method is always passed to mergeResults, so it is equivalent to just implement this functionality as extra decoration on the QueryRunner during mergeResults().
In the interests of potentially simplifying these interfaces, the recommendation is to actually not override this method and instead apply anything that might be needed here in the mergeResults() call.
preMergeQueryDecoration
in class QueryToolChest<Result<TopNResultValue>,TopNQuery>
runner
- The runner to be wrappedpublic QueryRunner<Result<TopNResultValue>> postMergeQueryDecoration(QueryRunner<Result<TopNResultValue>> runner)
QueryToolChest
In fact, the input value of this method is always the return value from mergeResults, so it is equivalent to just implement this functionality as extra decoration on the QueryRunner during mergeResults().
In the interests of potentially simplifying these interfaces, the recommendation is to actually not override this method and instead apply anything that might be needed here in the mergeResults() call.
postMergeQueryDecoration
in class QueryToolChest<Result<TopNResultValue>,TopNQuery>
runner
- The runner to be wrappedCopyright © 2011–2018. All rights reserved.