Package org.apache.druid.query

Class DruidMetrics

java.lang.Object

org.apache.druid.query.DruidMetrics

public class DruidMetrics
extends Object

Contains dimension names used while emitting metrics.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CATEGORY
static final String	DATASOURCE
static final String	DESCRIPTION
static final String	DURATION
static final String	ENGINE
static final String	GROUP_ID
static final String	ID
static final String	INTERVAL
static final String	PARTITION
static final String	PARTITIONING_TYPE
static final String	STATUS
static final String	STATUS_CODE
static final String	STREAM
static final String	SUBQUERY_ID
static final String	SUCCESS
static final String	SUPERVISOR_ID
static final String	TAGS
static final String	TASK_ACTION_TYPE
static final String	TASK_ID
static final String	TASK_INGESTION_MODE
static final String	TASK_STATUS
static final String	TASK_TYPE
static final String	TYPE
static final String	WORKER_VERSION

Constructor Summary

Constructors

Constructor	Description
DruidMetrics()

Method Summary

Modifier and Type	Method	Description
static int	computeStatusCode(Throwable error)	Computes the HTTP status code based on the query error (if any) for tagged metric emission.
static int	findNumComplexAggs(List<AggregatorFactory> aggs)
static <T> QueryMetrics<?>	makeRequestMetrics(GenericQueryMetricsFactory queryMetricsFactory, QueryToolChest<T,Query<T>> toolChest, Query<T> query, String remoteAddr)

Methods inherited from class java.lang.Object

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

Field Details

DATASOURCE

public static final String DATASOURCE

See Also:

• Constant Field Values

TYPE

public static final String TYPE

See Also:

• Constant Field Values

INTERVAL

public static final String INTERVAL

See Also:

• Constant Field Values

ID

public static final String ID

See Also:

• Constant Field Values

SUBQUERY_ID

public static final String SUBQUERY_ID

See Also:

• Constant Field Values

STATUS_CODE

public static final String STATUS_CODE

See Also:

• Constant Field Values

STATUS

public static final String STATUS

See Also:

• Constant Field Values

ENGINE

public static final String ENGINE

See Also:

• Constant Field Values

DURATION

public static final String DURATION

See Also:

• Constant Field Values

SUCCESS

public static final String SUCCESS

See Also:

• Constant Field Values

TASK_ID

public static final String TASK_ID

See Also:

• Constant Field Values

GROUP_ID

public static final String GROUP_ID

See Also:

• Constant Field Values

TASK_TYPE

public static final String TASK_TYPE

See Also:

• Constant Field Values

TASK_STATUS

public static final String TASK_STATUS

See Also:

• Constant Field Values

DESCRIPTION

public static final String DESCRIPTION

See Also:

• Constant Field Values

PARTITIONING_TYPE

public static final String PARTITIONING_TYPE

See Also:

• Constant Field Values

TASK_INGESTION_MODE

public static final String TASK_INGESTION_MODE

See Also:

• Constant Field Values

TASK_ACTION_TYPE

public static final String TASK_ACTION_TYPE

See Also:

• Constant Field Values

STREAM

public static final String STREAM

See Also:

• Constant Field Values

PARTITION

public static final String PARTITION

See Also:

• Constant Field Values

SUPERVISOR_ID

public static final String SUPERVISOR_ID

See Also:

• Constant Field Values

TAGS

public static final String TAGS

See Also:

• Constant Field Values

CATEGORY

public static final String CATEGORY

See Also:

• Constant Field Values

WORKER_VERSION

public static final String WORKER_VERSION

See Also:

• Constant Field Values

Constructor Details

DruidMetrics

public DruidMetrics()

Method Details

findNumComplexAggs

public static int findNumComplexAggs(List<AggregatorFactory> aggs)

makeRequestMetrics

public static <T> QueryMetrics<?> makeRequestMetrics(GenericQueryMetricsFactory queryMetricsFactory,
 QueryToolChest<T,Query<T>> toolChest,
 Query<T> query,
 String remoteAddr)

computeStatusCode

public static int computeStatusCode(@Nullable
 Throwable error)

Computes the HTTP status code based on the query error (if any) for tagged metric emission.

• If error is null: returns 200 (success)
• If error is a DruidException or QueryException: returns the corresponding status code
• Otherwise (unclassified error): returns 500 (internal server error)

Parameters:

error - The throwable error, or null if successful

Returns:

HTTP status code appropriate for the error