From 1cff629a969fcae35c304634f9cf66f88a174c08 Mon Sep 17 00:00:00 2001 From: Chandra Addala Date: Thu, 18 May 2017 11:10:05 -0500 Subject: [PATCH] Adding histogram for metrics search results size --- .../com/rackspacecloud/blueflood/io/AbstractElasticIO.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/blueflood-elasticsearch/src/main/java/com/rackspacecloud/blueflood/io/AbstractElasticIO.java b/blueflood-elasticsearch/src/main/java/com/rackspacecloud/blueflood/io/AbstractElasticIO.java index 6de343420..fdfa5d95b 100644 --- a/blueflood-elasticsearch/src/main/java/com/rackspacecloud/blueflood/io/AbstractElasticIO.java +++ b/blueflood-elasticsearch/src/main/java/com/rackspacecloud/blueflood/io/AbstractElasticIO.java @@ -35,6 +35,7 @@ public abstract class AbstractElasticIO implements DiscoveryIO { protected final Histogram batchHistogram = Metrics.histogram(getClass(), "Batch Sizes"); protected Meter classCastExceptionMeter = Metrics.meter(getClass(), "Failed Cast to IMetric"); protected Histogram queryBatchHistogram = Metrics.histogram(getClass(), "Query Batch Size"); + private final Histogram searchResultsSizeHistogram = Metrics.histogram(getClass(), "Metrics search results size"); public static String METRICS_TOKENS_AGGREGATE = "metric_tokens"; public static String ELASTICSEARCH_INDEX_NAME_WRITE = Configuration.getInstance().getStringProperty(ElasticIOConfig.ELASTICSEARCH_INDEX_NAME_WRITE); @@ -91,7 +92,7 @@ private List searchESByIndexes(String tenant, List queries multiSearchCtx.stop(); } - + searchResultsSizeHistogram.update(response.getHits().getHits().length); for (SearchHit hit : response.getHits().getHits()) { SearchResult result = convertHitToMetricDiscoveryResult(hit); results.add(result);