Package org.apache.druid.query.groupby

Class DefaultGroupByQueryMetrics

java.lang.Object

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

org.apache.druid.query.groupby.DefaultGroupByQueryMetrics

All Implemented Interfaces:

GroupByQueryMetrics, QueryMetrics<GroupByQuery>

public class DefaultGroupByQueryMetrics
extends DefaultQueryMetrics<GroupByQuery>
implements GroupByQueryMetrics

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
DefaultGroupByQueryMetrics()

Method Summary

Modifier and Type	Method	Description
void	granularity(GroupByQuery query)	Sets the granularity of BaseQuery.getGranularity() of the given query as dimension.
void	numComplexMetrics(GroupByQuery query)	Sets the number of "complex" metrics of the given groupBy query as dimension.
void	numDimensions(GroupByQuery query)	Sets the size of GroupByQuery.getDimensions() of the given query as dimension.
void	numMetrics(GroupByQuery query)	Sets the number of metrics of the given groupBy query as dimension.
void	query(GroupByQuery 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

DefaultGroupByQueryMetrics

public DefaultGroupByQueryMetrics()

Method Details

query

public void query(GroupByQuery query)

Description copied from interface: QueryMetrics

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

Specified by:

query in interface QueryMetrics<GroupByQuery>

Overrides:

query in class DefaultQueryMetrics<GroupByQuery>

numDimensions

public void numDimensions(GroupByQuery query)

Description copied from interface: GroupByQueryMetrics

Sets the size of GroupByQuery.getDimensions() of the given query as dimension.

Specified by:

numDimensions in interface GroupByQueryMetrics

numMetrics

public void numMetrics(GroupByQuery query)

Description copied from interface: GroupByQueryMetrics

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

Specified by:

numMetrics in interface GroupByQueryMetrics

numComplexMetrics

public void numComplexMetrics(GroupByQuery query)

Description copied from interface: GroupByQueryMetrics

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

granularity

public void granularity(GroupByQuery query)

Description copied from interface: GroupByQueryMetrics

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

Specified by:

granularity in interface GroupByQueryMetrics