Package org.apache.druid.query.timeseries

Class DefaultTimeseriesQueryMetrics

java.lang.Object

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

org.apache.druid.query.timeseries.DefaultTimeseriesQueryMetrics

All Implemented Interfaces:

QueryMetrics<TimeseriesQuery>, TimeseriesQueryMetrics

public class DefaultTimeseriesQueryMetrics
extends DefaultQueryMetrics<TimeseriesQuery>
implements TimeseriesQueryMetrics

Field Summary

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

builder, metrics, ownerThread, QUERY_BYTES, QUERY_CPU_TIME, QUERY_ON_DEMAND_LOAD_BATCH_TIME, QUERY_ON_DEMAND_LOAD_BYTES, QUERY_ON_DEMAND_LOAD_COUNT, QUERY_ON_DEMAND_LOAD_TIME_AVG, QUERY_ON_DEMAND_LOAD_TIME_MAX, QUERY_ON_DEMAND_WAIT_TIME_AVG, QUERY_ON_DEMAND_WAIT_TIME_MAX, QUERY_RESULT_CACHE_HIT, QUERY_SEGMENT_AND_CACHE_TIME, QUERY_SEGMENT_TIME, QUERY_TIME, QUERY_WAIT_TIME

Constructor Summary

Constructors

Constructor	Description
DefaultTimeseriesQueryMetrics()

Method Summary

Modifier and Type	Method	Description
void	granularity(TimeseriesQuery query)	Sets the granularity of BaseQuery.getGranularity() of the given query as dimension.
void	limit(TimeseriesQuery query)	Sets TimeseriesQuery.getLimit() of the given query as dimension.
void	numComplexMetrics(TimeseriesQuery query)	Sets the number of "complex" metrics of the given timeseries query as dimension.
void	numMetrics(TimeseriesQuery query)	Sets the number of metrics of the given timeseries query as dimension.
void	query(TimeseriesQuery query)	Pulls all information from the query object into dimensions of future metrics.

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, reportSegmentOnDemandLoadBytes, reportSegmentOnDemandLoadCount, reportSegmentOnDemandLoadTime, reportSegmentOnDemandLoadTimeAvg, reportSegmentOnDemandLoadTimeMax, reportSegmentOnDemandLoadWaitTimeAvg, reportSegmentOnDemandLoadWaitTimeMax, 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, reportSegmentOnDemandLoadBytes, reportSegmentOnDemandLoadCount, reportSegmentOnDemandLoadTime, reportSegmentOnDemandLoadTimeAvg, reportSegmentOnDemandLoadTimeMax, reportSegmentOnDemandLoadWaitTimeAvg, reportSegmentOnDemandLoadWaitTimeMax, reportSegmentRows, reportSegmentTime, reportWaitTime, segment, server, sqlQueryId, sqlQueryId, status, statusCode, subQueryId, success, vectorized

Constructor Details

DefaultTimeseriesQueryMetrics

public DefaultTimeseriesQueryMetrics()

Method Details

query

public void query(TimeseriesQuery query)

Description copied from interface: QueryMetrics

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

Specified by:

query in interface QueryMetrics<TimeseriesQuery>

Overrides:

query in class DefaultQueryMetrics<TimeseriesQuery>

limit

public void limit(TimeseriesQuery query)

Description copied from interface: TimeseriesQueryMetrics

Sets TimeseriesQuery.getLimit() of the given query as dimension.

Specified by:

limit in interface TimeseriesQueryMetrics

numMetrics

public void numMetrics(TimeseriesQuery query)

Description copied from interface: TimeseriesQueryMetrics

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

Specified by:

numMetrics in interface TimeseriesQueryMetrics

numComplexMetrics

public void numComplexMetrics(TimeseriesQuery query)

Description copied from interface: TimeseriesQueryMetrics

Sets the number of "complex" metrics of the given timeseries 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 TimeseriesQueryMetrics

granularity

public void granularity(TimeseriesQuery query)

Description copied from interface: TimeseriesQueryMetrics

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

Specified by:

granularity in interface TimeseriesQueryMetrics