public class DefaultTopNQueryMetrics extends DefaultQueryMetrics<TopNQuery> implements TopNQueryMetrics
builder, jsonMapper, metrics, ownerThread
Constructor and Description |
---|
DefaultTopNQueryMetrics(com.fasterxml.jackson.databind.ObjectMapper jsonMapper) |
Modifier and Type | Method and 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. |
checkModifiedFromOwnerThread, chunkInterval, context, dataSource, duration, emit, hasFilters, identity, interval, makeBitmapResultFactory, postFilters, preFilters, queryId, queryType, remoteAddress, reportBitmapConstructionTime, reportCpuTime, reportIntervalChunkTime, reportMetric, reportNodeBytes, reportNodeTime, reportNodeTimeToFirstByte, reportPreFilteredRows, reportQueryBytes, reportQueryTime, reportSegmentAndCacheTime, reportSegmentRows, reportSegmentTime, reportWaitTime, segment, server, setDimension, status, success
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
chunkInterval, context, dataSource, duration, emit, hasFilters, identity, interval, makeBitmapResultFactory, postFilters, preFilters, queryId, queryType, remoteAddress, reportBitmapConstructionTime, reportCpuTime, reportIntervalChunkTime, reportNodeBytes, reportNodeTime, reportNodeTimeToFirstByte, reportPreFilteredRows, reportQueryBytes, reportQueryTime, reportSegmentAndCacheTime, reportSegmentRows, reportSegmentTime, reportWaitTime, segment, server, status, success
public DefaultTopNQueryMetrics(com.fasterxml.jackson.databind.ObjectMapper jsonMapper)
public void query(TopNQuery query)
QueryMetrics
query
in interface QueryMetrics<TopNQuery>
query
in class DefaultQueryMetrics<TopNQuery>
public void threshold(TopNQuery query)
TopNQueryMetrics
TopNQuery.getThreshold()
of the given query as dimension.threshold
in interface TopNQueryMetrics
public void dimension(TopNQuery query)
TopNQueryMetrics
TopNQuery.getDimensionSpec()
.getDimension()
of the given query as dimension.dimension
in interface TopNQueryMetrics
public void numMetrics(TopNQuery query)
TopNQueryMetrics
numMetrics
in interface TopNQueryMetrics
public void numComplexMetrics(TopNQuery query)
TopNQueryMetrics
numComplexMetrics
in interface TopNQueryMetrics
public void granularity(TopNQuery query)
TopNQueryMetrics
BaseQuery.getGranularity()
of the given query as dimension.granularity
in interface TopNQueryMetrics
public void dimensionCardinality(int cardinality)
dimensionCardinality
in interface TopNQueryMetrics
public void algorithm(TopNAlgorithm algorithm)
algorithm
in interface TopNQueryMetrics
public void cursor(Cursor cursor)
TopNQueryMetrics
cursor
in interface TopNQueryMetrics
public void columnValueSelector(ColumnValueSelector columnValueSelector)
TopNQueryMetrics
columnValueSelector
in interface TopNQueryMetrics
public void numValuesPerPass(TopNParams params)
TopNQueryMetrics
TopNParams.getNumValuesPerPass()
of the query as dimension.numValuesPerPass
in interface TopNQueryMetrics
public TopNQueryMetrics addProcessedRows(long numRows)
TopNQueryMetrics
QueryMetrics.reportPreFilteredRows(long)
, because QueryMetrics.postFilters(java.util.List<io.druid.query.filter.Filter>)
are additionally applied. If there
are no postFilters, preFilteredRows and processedRows are equal.addProcessedRows
in interface TopNQueryMetrics
public void startRecordingScanTime()
TopNQueryMetrics
TopNQueryMetrics.stopRecordingScanTime()
wrap scanning of each cursor, processed for the
query.startRecordingScanTime
in interface TopNQueryMetrics
public TopNQueryMetrics stopRecordingScanTime()
TopNQueryMetrics
TopNQueryMetrics.startRecordingScanTime()
and this method wrap scanning of each cursor, processed for the query.stopRecordingScanTime
in interface TopNQueryMetrics
Copyright © 2011–2018. All rights reserved.