io.druid.query.select

Class DefaultSelectQueryMetrics

java.lang.Object

io.druid.query.select.DefaultSelectQueryMetrics

All Implemented Interfaces:

QueryMetrics<SelectQuery>, SelectQueryMetrics

public class DefaultSelectQueryMetrics
extends Object
implements SelectQueryMetrics

This class is implemented with delegation to another QueryMetrics for compatibility, see "Making subinterfaces of QueryMetrics for emitting custom dimensions and/or metrics for specific query types" section in QueryMetrics javadoc.

Constructor Summary

Constructors

Constructor and Description
DefaultSelectQueryMetrics(QueryMetrics<Query<?>> queryMetrics)

Method Summary

Modifier and Type	Method and Description
void	chunkInterval(org.joda.time.Interval interval)
void	context(SelectQuery query) Sets Query.getContext() of the given query as dimension.
void	dataSource(SelectQuery query) Sets Query.getDataSource() of the given query as dimension.
void	duration(SelectQuery query) Sets Query.getDuration() of the given query as dimension.
void	emit(ServiceEmitter emitter) Emits all metrics, registered since the last emit() call on this QueryMetrics object.
void	granularity(SelectQuery query) Sets the granularity of BaseQuery.getGranularity() of the given query as dimension.
void	hasFilters(SelectQuery query) Sets Query.hasFilters() of the given query as dimension.
void	identity(String identity) Sets identity of the requester for a query.
void	interval(SelectQuery query) Sets Query.getIntervals() of the given query as dimension.
BitmapResultFactory<?>	makeBitmapResultFactory(BitmapFactory factory) Creates a BitmapResultFactory which may record some information along bitmap construction from QueryMetrics.preFilters(List).
void	postFilters(List<Filter> postFilters)
void	preFilters(List<Filter> preFilters)
void	query(SelectQuery query) Pulls all information from the query object into dimensions of future metrics.
void	queryId(SelectQuery query) Sets Query.getId() of the given query as dimension.
void	queryType(SelectQuery query) Sets Query.getType() of the given query as dimension.
void	remoteAddress(String remoteAddress)
QueryMetrics	reportBitmapConstructionTime(long timeNs) Reports the time spent constructing bitmap from QueryMetrics.preFilters(List) of the query.
QueryMetrics	reportCpuTime(long timeNs) Registers "cpu time" metric.
QueryMetrics	reportIntervalChunkTime(long timeNs) Registers "interval chunk time" metric.
QueryMetrics	reportNodeBytes(long byteCount) Registers "node bytes" metric.
QueryMetrics	reportNodeTime(long timeNs) Registers "node time" metric.
QueryMetrics	reportNodeTimeToFirstByte(long timeNs) Registers "time to first byte" metric.
QueryMetrics	reportPreFilteredRows(long numRows) Reports the number of rows to scan in the segment after applying QueryMetrics.preFilters(List).
QueryMetrics	reportQueryBytes(long byteCount) Registers "query bytes" metric.
QueryMetrics	reportQueryTime(long timeNs) Registers "query time" metric.
QueryMetrics	reportSegmentAndCacheTime(long timeNs) Registers "segmentAndCache time" metric.
QueryMetrics	reportSegmentRows(long numRows) Reports the total number of rows in the processed segment.
QueryMetrics	reportSegmentTime(long timeNs) Registers "segment time" metric.
QueryMetrics	reportWaitTime(long timeNs) Registers "wait time" metric.
void	segment(String segmentIdentifier)
void	server(String host)
void	status(String status)
void	success(boolean success)

Methods inherited from class java.lang.Object

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

Constructor Detail

DefaultSelectQueryMetrics

public DefaultSelectQueryMetrics(QueryMetrics<Query<?>> queryMetrics)

Method Detail

query

public void query(SelectQuery query)

Description copied from interface: QueryMetrics

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

Specified by:

query in interface QueryMetrics<SelectQuery>

dataSource

public void dataSource(SelectQuery query)

Description copied from interface: QueryMetrics

Sets Query.getDataSource() of the given query as dimension.

Specified by:

dataSource in interface QueryMetrics<SelectQuery>

queryType

public void queryType(SelectQuery query)

Description copied from interface: QueryMetrics

Sets Query.getType() of the given query as dimension.

Specified by:

queryType in interface QueryMetrics<SelectQuery>

interval

public void interval(SelectQuery query)

Description copied from interface: QueryMetrics

Sets Query.getIntervals() of the given query as dimension.

Specified by:

interval in interface QueryMetrics<SelectQuery>

hasFilters

public void hasFilters(SelectQuery query)

Description copied from interface: QueryMetrics

Sets Query.hasFilters() of the given query as dimension.

Specified by:

hasFilters in interface QueryMetrics<SelectQuery>

duration

public void duration(SelectQuery query)

Description copied from interface: QueryMetrics

Sets Query.getDuration() of the given query as dimension.

Specified by:

duration in interface QueryMetrics<SelectQuery>

queryId

public void queryId(SelectQuery query)

Description copied from interface: QueryMetrics

Sets Query.getId() of the given query as dimension.

Specified by:

queryId in interface QueryMetrics<SelectQuery>

granularity

public void granularity(SelectQuery query)

Description copied from interface: SelectQueryMetrics

Sets the granularity of BaseQuery.getGranularity() of the given query as dimension. This method is going to be used in "full" metrics impl, see https://github.com/druid-io/druid/pull/4570#issuecomment-319458229

Specified by:

granularity in interface SelectQueryMetrics

context

public void context(SelectQuery query)

Description copied from interface: QueryMetrics

Sets Query.getContext() of the given query as dimension.

Specified by:

context in interface QueryMetrics<SelectQuery>

server

public void server(String host)

Specified by:

server in interface QueryMetrics<SelectQuery>

remoteAddress

public void remoteAddress(String remoteAddress)

Specified by:

remoteAddress in interface QueryMetrics<SelectQuery>

status

public void status(String status)

Specified by:

status in interface QueryMetrics<SelectQuery>

success

public void success(boolean success)

Specified by:

success in interface QueryMetrics<SelectQuery>

segment

public void segment(String segmentIdentifier)

Specified by:

segment in interface QueryMetrics<SelectQuery>

chunkInterval

public void chunkInterval(org.joda.time.Interval interval)

Specified by:

chunkInterval in interface QueryMetrics<SelectQuery>

preFilters

public void preFilters(List<Filter> preFilters)

Specified by:

preFilters in interface QueryMetrics<SelectQuery>

postFilters

public void postFilters(List<Filter> postFilters)

Specified by:

postFilters in interface QueryMetrics<SelectQuery>

identity

public void identity(String identity)

Description copied from interface: QueryMetrics

Sets identity of the requester for a query. See AuthenticationResult.

Specified by:

identity in interface QueryMetrics<SelectQuery>

makeBitmapResultFactory

public BitmapResultFactory<?> makeBitmapResultFactory(BitmapFactory factory)

Description copied from interface: QueryMetrics

Creates a BitmapResultFactory which may record some information along bitmap construction from QueryMetrics.preFilters(List). The returned BitmapResultFactory may add some dimensions to this QueryMetrics from it's BitmapResultFactory.toImmutableBitmap(Object) method. See BitmapResultFactory Javadoc for more information.

Specified by:

makeBitmapResultFactory in interface QueryMetrics<SelectQuery>

reportQueryTime

public QueryMetrics reportQueryTime(long timeNs)

Description copied from interface: QueryMetrics

Registers "query time" metric.

Specified by:

reportQueryTime in interface QueryMetrics<SelectQuery>

reportQueryBytes

public QueryMetrics reportQueryBytes(long byteCount)

Description copied from interface: QueryMetrics

Registers "query bytes" metric.

Specified by:

reportQueryBytes in interface QueryMetrics<SelectQuery>

reportWaitTime

public QueryMetrics reportWaitTime(long timeNs)

Description copied from interface: QueryMetrics

Registers "wait time" metric.

Specified by:

reportWaitTime in interface QueryMetrics<SelectQuery>

reportSegmentTime

public QueryMetrics reportSegmentTime(long timeNs)

Description copied from interface: QueryMetrics

Registers "segment time" metric.

Specified by:

reportSegmentTime in interface QueryMetrics<SelectQuery>

reportSegmentAndCacheTime

public QueryMetrics reportSegmentAndCacheTime(long timeNs)

Description copied from interface: QueryMetrics

Registers "segmentAndCache time" metric.

Specified by:

reportSegmentAndCacheTime in interface QueryMetrics<SelectQuery>

reportIntervalChunkTime

public QueryMetrics reportIntervalChunkTime(long timeNs)

Description copied from interface: QueryMetrics

Registers "interval chunk time" metric.

Specified by:

reportIntervalChunkTime in interface QueryMetrics<SelectQuery>

reportCpuTime

public QueryMetrics reportCpuTime(long timeNs)

Description copied from interface: QueryMetrics

Registers "cpu time" metric.

Specified by:

reportCpuTime in interface QueryMetrics<SelectQuery>

reportNodeTimeToFirstByte

public QueryMetrics reportNodeTimeToFirstByte(long timeNs)

Description copied from interface: QueryMetrics

Registers "time to first byte" metric.

Specified by:

reportNodeTimeToFirstByte in interface QueryMetrics<SelectQuery>

reportNodeTime

public QueryMetrics reportNodeTime(long timeNs)

Description copied from interface: QueryMetrics

Registers "node time" metric.

Specified by:

reportNodeTime in interface QueryMetrics<SelectQuery>

reportNodeBytes

public QueryMetrics reportNodeBytes(long byteCount)

Description copied from interface: QueryMetrics

Registers "node bytes" metric.

Specified by:

reportNodeBytes in interface QueryMetrics<SelectQuery>

reportBitmapConstructionTime

public QueryMetrics reportBitmapConstructionTime(long timeNs)

Description copied from interface: QueryMetrics

Reports the time spent constructing bitmap from QueryMetrics.preFilters(List) of the query. Not reported, if there are no preFilters.

Specified by:

reportBitmapConstructionTime in interface QueryMetrics<SelectQuery>

reportSegmentRows

public QueryMetrics reportSegmentRows(long numRows)

Description copied from interface: QueryMetrics

Reports the total number of rows in the processed segment.

Specified by:

reportSegmentRows in interface QueryMetrics<SelectQuery>

reportPreFilteredRows

public QueryMetrics reportPreFilteredRows(long numRows)

Description copied from interface: QueryMetrics

Reports the number of rows to scan in the segment after applying QueryMetrics.preFilters(List). If the are no preFilters, this metric is equal to QueryMetrics.reportSegmentRows(long).

Specified by:

reportPreFilteredRows in interface QueryMetrics<SelectQuery>

emit

public void emit(ServiceEmitter emitter)

Description copied from interface: QueryMetrics

Emits all metrics, registered since the last emit() call on this QueryMetrics object.

Specified by:

emit in interface QueryMetrics<SelectQuery>