summaryrefslogtreecommitdiffstats
path: root/container-search
diff options
context:
space:
mode:
authorHenning Baldersheim <balder@yahoo-inc.com>2018-03-08 09:48:34 +0100
committerHenning Baldersheim <balder@yahoo-inc.com>2018-03-13 22:19:39 +0100
commite093acfb9f0ba1dd3823ff48c1019c10d60b7c4c (patch)
tree2aab738cd7834bab9567c2f4d24e08eee59066ae /container-search
parente4049b4781e4406a87f6561423144e8edcba12c8 (diff)
Add final to members
Diffstat (limited to 'container-search')
-rw-r--r--container-search/src/main/java/com/yahoo/prelude/statistics/StatisticsSearcher.java64
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);
}