Add the druid artifact version to metrics when emitted

apache · Nov 12, 2015 · af34e9c · af34e9c
1 parent 4f46d45
commit af34e9c
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/processing/src/main/java/io/druid/query/DruidMetrics.java b/processing/src/main/java/io/druid/query/DruidMetrics.java
@@ -20,6 +20,7 @@
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.fasterxml.jackson.databind.ObjectMapper;
 import com.google.common.base.Function;
+import com.google.common.base.Strings;
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.Lists;
 import com.metamx.emitter.service.ServiceMetricEvent;
@@ -37,6 +38,7 @@ public class DruidMetrics
   public final static String INTERVAL = "interval";
   public final static String ID = "id";
   public final static String STATUS = "status";
+  public final static String VERSION = "version";
 
   // task metrics
   public final static String TASK_TYPE = "taskType";
@@ -59,6 +61,7 @@ public static int findNumComplexAggs(List<AggregatorFactory> aggs)
   public static <T> ServiceMetricEvent.Builder makePartialQueryTimeMetric(Query<T> query)
   {
     return new ServiceMetricEvent.Builder()
+        .setDimension(VERSION, Strings.nullToEmpty(DruidMetrics.class.getPackage().getImplementationVersion()))
         .setDimension(DATASOURCE, DataSourceUtil.getMetricName(query.getDataSource()))
         .setDimension(TYPE, query.getType())
         .setDimension(