summaryrefslogtreecommitdiffstats
path: root/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
diff options
context:
space:
mode:
Diffstat (limited to 'container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java')
-rw-r--r--container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java31
1 files changed, 15 insertions, 16 deletions
diff --git a/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java b/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
index e315bee6040..9af5d5ecd7b 100644
--- a/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
+++ b/container-search/src/main/java/com/yahoo/prelude/cluster/ClusterSearcher.java
@@ -107,14 +107,14 @@ public class ClusterSearcher extends Searcher {
this.hasher = new Hasher();
this.fs4ResourcePool = listeners;
monitor = new ClusterMonitor(this, monitorConfig, vipStatus);
- final int searchClusterIndex = clusterConfig.clusterId();
+ int searchClusterIndex = clusterConfig.clusterId();
clusterModelName = clusterConfig.clusterName();
- final QrSearchersConfig.Searchcluster searchClusterConfig = getSearchClusterConfigFromClusterName(qrsConfig, clusterModelName);
+ QrSearchersConfig.Searchcluster searchClusterConfig = getSearchClusterConfigFromClusterName(qrsConfig, clusterModelName);
documentTypes = new LinkedHashSet<>();
failoverToRemote = clusterConfig.failoverToRemote();
Dispatcher dispatcher = new Dispatcher(dispatchConfig);
- final String eventName = clusterModelName + ".cache_hit_ratio";
+ String eventName = clusterModelName + ".cache_hit_ratio";
cacheHitRatio = new Value(eventName, manager, new Value.Parameters()
.setNameExtension(false).setLogRaw(false).setLogMean(true));
@@ -122,36 +122,35 @@ public class ClusterSearcher extends Searcher {
maxQueryCacheTimeout = ParameterParser.asMilliSeconds(clusterConfig.maxQueryCacheTimeout(),
DEFAULT_MAX_QUERY_CACHE_TIMEOUT);
- final CacheParams cacheParams = new CacheParams(createCache(clusterConfig, clusterModelName));
- final SummaryParameters docSumParams = new SummaryParameters(qrsConfig
+ CacheParams cacheParams = new CacheParams(createCache(clusterConfig, clusterModelName));
+ SummaryParameters docSumParams = new SummaryParameters(qrsConfig
.com().yahoo().prelude().fastsearch().FastSearcher().docsum()
.defaultclass());
- for (final DocumentdbInfoConfig.Documentdb docDb : documentDbConfig.documentdb()) {
+ for (DocumentdbInfoConfig.Documentdb docDb : documentDbConfig.documentdb()) {
String docTypeName = docDb.name();
documentTypes.add(docTypeName);
- for (final DocumentdbInfoConfig.Documentdb.Rankprofile profile : docDb.rankprofile()) {
+ for (DocumentdbInfoConfig.Documentdb.Rankprofile profile : docDb.rankprofile()) {
addValidRankProfile(profile.name(), docTypeName);
}
}
boolean gotExpectedBackend = false;
if (searchClusterConfig.indexingmode() == STREAMING) {
- final VdsStreamingSearcher searcher = vdsCluster(searchClusterIndex,
- searchClusterConfig, cacheParams, emulationConfig, docSumParams,
- documentDbConfig);
+ VdsStreamingSearcher searcher = vdsCluster(searchClusterIndex,
+ searchClusterConfig, cacheParams, emulationConfig, docSumParams,
+ documentDbConfig);
addBackendSearcher(searcher);
gotExpectedBackend = true;
} else {
for (int i = 0; i < searchClusterConfig.dispatcher().size(); i++) {
- final Backend b = createBackend(
- searchClusterConfig.dispatcher(i));
- final FastSearcher searcher = searchDispatch(searchClusterIndex,
- searchClusterConfig, cacheParams, emulationConfig, docSumParams,
- documentDbConfig, b, dispatcher, i);
+ Backend b = createBackend(searchClusterConfig.dispatcher(i));
+ FastSearcher searcher = searchDispatch(searchClusterIndex,
+ searchClusterConfig, cacheParams, emulationConfig, docSumParams,
+ documentDbConfig, b, dispatcher, i);
try {
- searcher.setLocalDispatching(!isRemote(searchClusterConfig.dispatcher(i).host()));
+ searcher.setLocalDispatching( ! isRemote(searchClusterConfig.dispatcher(i).host()));
} catch (UnknownHostException e) {
throw new RuntimeException(e);
}