diff options
author | Henning Baldersheim <balder@yahoo-inc.com> | 2018-03-08 09:48:34 +0100 |
---|---|---|
committer | Henning Baldersheim <balder@yahoo-inc.com> | 2018-03-13 22:19:39 +0100 |
commit | e093acfb9f0ba1dd3823ff48c1019c10d60b7c4c (patch) | |
tree | 2aab738cd7834bab9567c2f4d24e08eee59066ae /container-search | |
parent | e4049b4781e4406a87f6561423144e8edcba12c8 (diff) |
Add final to members
Diffstat (limited to 'container-search')
-rw-r--r-- | container-search/src/main/java/com/yahoo/prelude/statistics/StatisticsSearcher.java | 64 |
1 files changed, 31 insertions, 33 deletions
diff --git a/container-search/src/main/java/com/yahoo/prelude/statistics/StatisticsSearcher.java b/container-search/src/main/java/com/yahoo/prelude/statistics/StatisticsSearcher.java index 1e1191cb1e4..93cdebbf93b 100644 --- a/container-search/src/main/java/com/yahoo/prelude/statistics/StatisticsSearcher.java +++ b/container-search/src/main/java/com/yahoo/prelude/statistics/StatisticsSearcher.java @@ -56,18 +56,18 @@ public class StatisticsSearcher extends Searcher { private static final String ACTIVE_QUERIES_METRIC = "active_queries"; private static final String PEAK_QPS_METRIC = "peak_qps"; - private Counter queries; // basic counter - private Counter failedQueries; // basic counter - private Counter nullQueries; // basic counter - private Counter illegalQueries; // basic counter - private Value queryLatency; // mean pr 5 min - private Value queryLatencyBuckets; - private Value maxQueryLatency; // separate to avoid name mangling + private final Counter queries; // basic counter + private final Counter failedQueries; // basic counter + private final Counter nullQueries; // basic counter + private final Counter illegalQueries; // basic counter + private final Value queryLatency; // mean pr 5 min + private final Value queryLatencyBuckets; + private final Value maxQueryLatency; // separate to avoid name mangling @SuppressWarnings("unused") // all the work is done by the callback - private Value activeQueries; // raw measure every 5 minutes - private Value peakQPS; // peak 1s QPS - private Counter emptyResults; // number of results containing no concrete hits - private Value hitsPerQuery; // mean number of hits per query + private final Value activeQueries; // raw measure every 5 minutes + private final Value peakQPS; // peak 1s QPS + private final Counter emptyResults; // number of results containing no concrete hits + private final Value hitsPerQuery; // mean number of hits per query private final PeakQpsReporter peakQpsReporter; @@ -77,26 +77,6 @@ public class StatisticsSearcher extends Searcher { private Map<String, Metric.Context> statePageOnlyContexts = new CopyOnWriteHashMap<>(); private java.util.Timer scheduler = new java.util.Timer(true); - private void initEvents(com.yahoo.statistics.Statistics manager, MetricReceiver metricReceiver) { - queries = new Counter(QUERIES_METRIC, manager, false); - failedQueries = new Counter(FAILED_QUERIES_METRIC, manager, false); - nullQueries = new Counter("null_queries", manager, false); - illegalQueries = new Counter("illegal_queries", manager, false); - queryLatency = new Value(MEAN_QUERY_LATENCY_METRIC, manager, - new Value.Parameters().setLogRaw(false).setLogMean(true).setNameExtension(false)); - maxQueryLatency = new Value(MAX_QUERY_LATENCY_METRIC, manager, - new Value.Parameters().setLogRaw(false).setLogMax(true).setNameExtension(false)); - queryLatencyBuckets = Value.buildValue("query_latency", manager, null); - activeQueries = new Value(ACTIVE_QUERIES_METRIC, manager, - new Value.Parameters().setLogRaw(true).setCallback(new ActivitySampler())); - peakQPS = new Value(PEAK_QPS_METRIC, manager, new Value.Parameters().setLogRaw(false).setLogMax(true) - .setNameExtension(false)); - hitsPerQuery = new Value(HITS_PER_QUERY_METRIC, manager, - new Value.Parameters().setLogRaw(false).setLogMean(true).setNameExtension(false)); - emptyResults = new Counter(EMPTY_RESULTS_METRIC, manager, false); - metricReceiver.declareGauge(QUERY_LATENCY_METRIC, Optional.empty(), new MetricSettings.Builder().histogram(true).build()); - } - // Callback to measure queries in flight every five minutes private class ActivitySampler implements Callback { public void run(Handle h, boolean firstRun) { @@ -137,7 +117,7 @@ public class StatisticsSearcher extends Searcher { prevMaxQPSTime = now; queriesForQPS = 0; } - public void countQuery() { + void countQuery() { synchronized (this) { ++queriesForQPS; } @@ -147,7 +127,25 @@ public class StatisticsSearcher extends Searcher { public StatisticsSearcher(com.yahoo.statistics.Statistics manager, Metric metric, MetricReceiver metricReceiver) { this.peakQpsReporter = new PeakQpsReporter(); this.metric = metric; - initEvents(manager, metricReceiver); + + queries = new Counter(QUERIES_METRIC, manager, false); + failedQueries = new Counter(FAILED_QUERIES_METRIC, manager, false); + nullQueries = new Counter("null_queries", manager, false); + illegalQueries = new Counter("illegal_queries", manager, false); + queryLatency = new Value(MEAN_QUERY_LATENCY_METRIC, manager, + new Value.Parameters().setLogRaw(false).setLogMean(true).setNameExtension(false)); + maxQueryLatency = new Value(MAX_QUERY_LATENCY_METRIC, manager, + new Value.Parameters().setLogRaw(false).setLogMax(true).setNameExtension(false)); + queryLatencyBuckets = Value.buildValue("query_latency", manager, null); + activeQueries = new Value(ACTIVE_QUERIES_METRIC, manager, + new Value.Parameters().setLogRaw(true).setCallback(new ActivitySampler())); + peakQPS = new Value(PEAK_QPS_METRIC, manager, new Value.Parameters().setLogRaw(false).setLogMax(true) + .setNameExtension(false)); + hitsPerQuery = new Value(HITS_PER_QUERY_METRIC, manager, + new Value.Parameters().setLogRaw(false).setLogMean(true).setNameExtension(false)); + emptyResults = new Counter(EMPTY_RESULTS_METRIC, manager, false); + metricReceiver.declareGauge(QUERY_LATENCY_METRIC, Optional.empty(), new MetricSettings.Builder().histogram(true).build()); + scheduler.schedule(peakQpsReporter, 1000, 1000); } |