Package org.apache.druid.query.topn

Class DefaultTopNQueryMetrics

java.lang.Object

org.apache.druid.query.DefaultQueryMetrics<TopNQuery>

org.apache.druid.query.topn.DefaultTopNQueryMetrics

All Implemented Interfaces:

QueryMetrics<TopNQuery>, TopNQueryMetrics

public class DefaultTopNQueryMetrics
extends DefaultQueryMetrics<TopNQuery>
implements TopNQueryMetrics

Field Summary

Fields inherited from class org.apache.druid.query.DefaultQueryMetrics

builder, metrics, ownerThread, QUERY_RESULT_CACHE_HIT, QUERY_SEGMENT_AND_CACHE_TIME, QUERY_SEGMENT_TIME, QUERY_WAIT_TIME

Constructor Summary

Constructors

Constructor	Description
DefaultTopNQueryMetrics()

Method Summary

Modifier and Type	Method	Description
TopNQueryMetrics	addProcessedRows(long numRows)	Called with the number of rows, processed via each cursor, processed for the query within the segment.
void	algorithm(TopNAlgorithm algorithm)
void	columnValueSelector(ColumnValueSelector columnValueSelector)	This method is called exactly once with the columnValueSelector object of each cursor, processed for the query.
void	cursor(Cursor cursor)	This method is called exactly once with each cursor, processed for the query.
void	dimension(TopNQuery query)	Sets TopNQuery.getDimensionSpec().getDimension() of the given query as dimension.
void	dimensionCardinality(int cardinality)
void	granularity(TopNQuery query)	Sets the granularity of BaseQuery.getGranularity() of the given query as dimension.
void	numComplexMetrics(TopNQuery query)	Sets the number of "complex" metrics of the given topN query as dimension.
void	numMetrics(TopNQuery query)	Sets the number of metrics of the given topN query as dimension.
void	numValuesPerPass(TopNParams params)	This method may set TopNParams.getNumValuesPerPass() of the query as dimension.
void	query(TopNQuery query)	Pulls all information from the query object into dimensions of future metrics.
void	startRecordingScanTime()	Calls to this method and TopNQueryMetrics.stopRecordingScanTime() wrap scanning of each cursor, processed for the query.
TopNQueryMetrics	stopRecordingScanTime()	Calls of TopNQueryMetrics.startRecordingScanTime() and this method wrap scanning of each cursor, processed for the query.
void	threshold(TopNQuery query)	Sets TopNQuery.getThreshold() of the given query as dimension.

Methods inherited from class org.apache.druid.query.DefaultQueryMetrics

checkModifiedFromOwnerThread, context, dataSource, duration, emit, getIntervalsAsStringArray, getTableNamesAsString, hasFilters, identity, interval, makeBitmapResultFactory, parallelMergeParallelism, projection, queryId, queryId, queryType, remoteAddress, reportBackPressureTime, reportBitmapConstructionTime, reportCpuTime, reportMetric, reportNodeBytes, reportNodeTime, reportNodeTimeToFirstByte, reportParallelMergeFastestPartitionTime, reportParallelMergeInputRows, reportParallelMergeInputSequences, reportParallelMergeOutputRows, reportParallelMergeParallelism, reportParallelMergeSlowestPartitionTime, reportParallelMergeTaskCount, reportParallelMergeTotalCpuTime, reportParallelMergeTotalTime, reportPreFilteredRows, reportQueriedSegmentCount, reportQueryBytes, reportQueryTime, reportResultCachePoll, reportSegmentAndCacheTime, reportSegmentRows, reportSegmentTime, reportWaitTime, segment, server, setDimension, sqlQueryId, sqlQueryId, status, statusCode, subQueryId, success, vectorized

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.druid.query.QueryMetrics

context, dataSource, duration, emit, filterBundle, hasFilters, identity, interval, makeBitmapResultFactory, parallelMergeParallelism, postFilters, preFilters, projection, queryId, queryId, queryType, remoteAddress, reportBackPressureTime, reportBitmapConstructionTime, reportCpuTime, reportNodeBytes, reportNodeTime, reportNodeTimeToFirstByte, reportParallelMergeFastestPartitionTime, reportParallelMergeInputRows, reportParallelMergeInputSequences, reportParallelMergeOutputRows, reportParallelMergeParallelism, reportParallelMergeSlowestPartitionTime, reportParallelMergeTaskCount, reportParallelMergeTotalCpuTime, reportParallelMergeTotalTime, reportPreFilteredRows, reportQueriedSegmentCount, reportQueryBytes, reportQueryTime, reportResultCachePoll, reportSegmentAndCacheTime, reportSegmentRows, reportSegmentTime, reportWaitTime, segment, server, sqlQueryId, sqlQueryId, status, statusCode, subQueryId, success, vectorized

Constructor Details

DefaultTopNQueryMetrics

public DefaultTopNQueryMetrics()

Method Details

query

public void query(TopNQuery query)

Description copied from interface: QueryMetrics

Pulls all information from the query object into dimensions of future metrics.

Specified by:

query in interface QueryMetrics<TopNQuery>

Overrides:

query in class DefaultQueryMetrics<TopNQuery>

threshold

public void threshold(TopNQuery query)

Description copied from interface: TopNQueryMetrics

Sets TopNQuery.getThreshold() of the given query as dimension.

Specified by:

threshold in interface TopNQueryMetrics

dimension

public void dimension(TopNQuery query)

Description copied from interface: TopNQueryMetrics

Sets TopNQuery.getDimensionSpec().getDimension() of the given query as dimension.

Specified by:

dimension in interface TopNQueryMetrics

numMetrics

public void numMetrics(TopNQuery query)

Description copied from interface: TopNQueryMetrics

Sets the number of metrics of the given topN query as dimension.

Specified by:

numMetrics in interface TopNQueryMetrics

numComplexMetrics

public void numComplexMetrics(TopNQuery query)

Description copied from interface: TopNQueryMetrics

Sets the number of "complex" metrics of the given topN query as dimension. By default it is assumed that "complex" metric is a metric of not long or double type, but it could be redefined in the implementation of this method.

Specified by:

numComplexMetrics in interface TopNQueryMetrics

granularity

public void granularity(TopNQuery query)

Description copied from interface: TopNQueryMetrics

Sets the granularity of BaseQuery.getGranularity() of the given query as dimension.

Specified by:

granularity in interface TopNQueryMetrics

dimensionCardinality

public void dimensionCardinality(int cardinality)

Specified by:

dimensionCardinality in interface TopNQueryMetrics

algorithm

public void algorithm(TopNAlgorithm algorithm)

Specified by:

algorithm in interface TopNQueryMetrics

cursor

public void cursor(Cursor cursor)

Description copied from interface: TopNQueryMetrics

This method is called exactly once with each cursor, processed for the query.

Specified by:

cursor in interface TopNQueryMetrics

columnValueSelector

public void columnValueSelector(ColumnValueSelector columnValueSelector)

Description copied from interface: TopNQueryMetrics

This method is called exactly once with the columnValueSelector object of each cursor, processed for the query.

Specified by:

columnValueSelector in interface TopNQueryMetrics

numValuesPerPass

public void numValuesPerPass(TopNParams params)

Description copied from interface: TopNQueryMetrics

This method may set TopNParams.getNumValuesPerPass() of the query as dimension.

Specified by:

numValuesPerPass in interface TopNQueryMetrics

addProcessedRows

public TopNQueryMetrics addProcessedRows(long numRows)

Description copied from interface: TopNQueryMetrics

Called with the number of rows, processed via each cursor, processed for the query within the segment. The total number of processed rows, reported via this method for a TopNQueryMetrics instance, is smaller or equal to QueryMetrics.reportPreFilteredRows(long), because matchers from QueryMetrics.filterBundle(FilterBundle.BundleInfo) are additionally applied. If there are no postFilters, preFilteredRows and processedRows are equal.

Specified by:

addProcessedRows in interface TopNQueryMetrics

startRecordingScanTime

public void startRecordingScanTime()

Description copied from interface: TopNQueryMetrics

Calls to this method and TopNQueryMetrics.stopRecordingScanTime() wrap scanning of each cursor, processed for the query.

Specified by:

startRecordingScanTime in interface TopNQueryMetrics

stopRecordingScanTime

public TopNQueryMetrics stopRecordingScanTime()

Description copied from interface: TopNQueryMetrics

Calls of TopNQueryMetrics.startRecordingScanTime() and this method wrap scanning of each cursor, processed for the query.

Specified by:

stopRecordingScanTime in interface TopNQueryMetrics