You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@lucene.apache.org by da...@apache.org on 2018/10/23 00:05:49 UTC
[28/52] [abbrv] [partial] lucene-solr:jira/gradle: Add gradle support
for Solr
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/0ae21ad0/solr/core/src/java/org/apache/solr/core/QuerySenderListener.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/core/QuerySenderListener.java b/solr/core/src/java/org/apache/solr/core/QuerySenderListener.java
deleted file mode 100644
index 9037ef3..0000000
--- a/solr/core/src/java/org/apache/solr/core/QuerySenderListener.java
+++ /dev/null
@@ -1,105 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.solr.core;
-
-import java.lang.invoke.MethodHandles;
-import java.util.List;
-
-import org.apache.solr.common.params.CommonParams;
-import org.apache.solr.common.util.NamedList;
-import org.apache.solr.request.LocalSolrQueryRequest;
-import org.apache.solr.request.SolrQueryRequest;
-import org.apache.solr.request.SolrRequestInfo;
-import org.apache.solr.response.ResultContext;
-import org.apache.solr.response.SolrQueryResponse;
-import org.apache.solr.search.DocIterator;
-import org.apache.solr.search.DocList;
-import org.apache.solr.search.SolrIndexSearcher;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import static org.apache.solr.common.params.CommonParams.DISTRIB;
-
-/**
- *
- */
-public class QuerySenderListener extends AbstractSolrEventListener {
- private static final Logger log = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
-
- public QuerySenderListener(SolrCore core) {
- super(core);
- }
-
- @Override
- public void newSearcher(SolrIndexSearcher newSearcher, SolrIndexSearcher currentSearcher) {
- final SolrIndexSearcher searcher = newSearcher;
- log.info("QuerySenderListener sending requests to " + newSearcher);
- List<NamedList> allLists = (List<NamedList>)getArgs().get("queries");
- if (allLists == null) return;
- boolean createNewReqInfo = SolrRequestInfo.getRequestInfo() == null;
- for (NamedList nlst : allLists) {
- SolrQueryRequest req = null;
- try {
- // bind the request to a particular searcher (the newSearcher)
- NamedList params = addEventParms(currentSearcher, nlst);
- // for this, we default to distrib = false
- if (params.get(DISTRIB) == null) {
- params.add(DISTRIB, false);
- }
- req = new LocalSolrQueryRequest(getCore(),params) {
- @Override public SolrIndexSearcher getSearcher() { return searcher; }
- @Override public void close() { }
- };
-
- SolrQueryResponse rsp = new SolrQueryResponse();
- if (createNewReqInfo) {
- // SolrRequerstInfo for this thread could have been transferred from the parent
- // thread.
- SolrRequestInfo.setRequestInfo(new SolrRequestInfo(req, rsp));
- }
- getCore().execute(getCore().getRequestHandler(req.getParams().get(CommonParams.QT)), req, rsp);
-
- // Retrieve the Document instances (not just the ids) to warm
- // the OS disk cache, and any Solr document cache. Only the top
- // level values in the NamedList are checked for DocLists.
- NamedList values = rsp.getValues();
- for (int i=0; i<values.size(); i++) {
- Object o = values.getVal(i);
- if (o instanceof ResultContext) {
- o = ((ResultContext)o).getDocList();
- }
- if (o instanceof DocList) {
- DocList docs = (DocList)o;
- for (DocIterator iter = docs.iterator(); iter.hasNext();) {
- newSearcher.doc(iter.nextDoc());
- }
- }
- }
-
- } catch (Exception e) {
- // do nothing... we want to continue with the other requests.
- // the failure should have already been logged.
- } finally {
- if (req != null) req.close();
- if (createNewReqInfo) SolrRequestInfo.clearRequestInfo();
- }
- }
- log.info("QuerySenderListener done.");
- }
-
-
-}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/0ae21ad0/solr/core/src/java/org/apache/solr/core/RAMDirectoryFactory.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/core/RAMDirectoryFactory.java b/solr/core/src/java/org/apache/solr/core/RAMDirectoryFactory.java
deleted file mode 100644
index 25d0a1c..0000000
--- a/solr/core/src/java/org/apache/solr/core/RAMDirectoryFactory.java
+++ /dev/null
@@ -1,47 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.solr.core;
-
-import java.io.IOException;
-
-import org.apache.lucene.store.Directory;
-import org.apache.lucene.store.LockFactory;
-import org.apache.lucene.store.RAMDirectory;
-import org.apache.lucene.store.SingleInstanceLockFactory;
-import org.apache.solr.common.SolrException;
-import org.apache.solr.common.SolrException.ErrorCode;
-
-/**
- * Factory to instantiate {@link org.apache.lucene.store.RAMDirectory}
- */
-public class RAMDirectoryFactory extends EphemeralDirectoryFactory {
-
- @Override
- protected LockFactory createLockFactory(String rawLockType) throws IOException {
- if (!(rawLockType == null || DirectoryFactory.LOCK_TYPE_SINGLE.equalsIgnoreCase(rawLockType.trim()))) {
- throw new SolrException(ErrorCode.FORBIDDEN,
- "RAMDirectory can only be used with the '"+DirectoryFactory.LOCK_TYPE_SINGLE+"' lock factory type.");
- }
- return new SingleInstanceLockFactory();
- }
-
- @Override
- protected Directory create(String path, LockFactory lockFactory, DirContext dirContext) throws IOException {
- return new RAMDirectory(lockFactory);
- }
-
-}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/0ae21ad0/solr/core/src/java/org/apache/solr/core/RequestHandlers.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/core/RequestHandlers.java b/solr/core/src/java/org/apache/solr/core/RequestHandlers.java
deleted file mode 100644
index dd06fa5..0000000
--- a/solr/core/src/java/org/apache/solr/core/RequestHandlers.java
+++ /dev/null
@@ -1,170 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.solr.core;
-
-import java.lang.invoke.MethodHandles;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
-
-import org.apache.solr.common.util.StrUtils;
-import org.apache.solr.request.SolrRequestHandler;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- */
-public final class RequestHandlers {
- private static final Logger log = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
-
- protected final SolrCore core;
-
- final PluginBag<SolrRequestHandler> handlers;
-
- /**
- * Trim the trailing '/' if it's there, and convert null to empty string.
- *
- * we want:
- * /update/csv and
- * /update/csv/
- * to map to the same handler
- *
- */
- public static String normalize( String p )
- {
- if(p == null) return "";
- if( p.endsWith( "/" ) && p.length() > 1 )
- return p.substring( 0, p.length()-1 );
-
- return p;
- }
-
- public RequestHandlers(SolrCore core) {
- this.core = core;
- // we need a thread safe registry since methods like register are currently documented to be thread safe.
- handlers = new PluginBag<>(SolrRequestHandler.class, core, true);
- }
-
- /**
- * @return the RequestHandler registered at the given name
- */
- public SolrRequestHandler get(String handlerName) {
- return handlers.get(normalize(handlerName));
- }
-
- /**
- * Handlers must be initialized before calling this function. As soon as this is
- * called, the handler can immediately accept requests.
- *
- * This call is thread safe.
- *
- * @return the previous handler at the given path or null
- */
- public SolrRequestHandler register( String handlerName, SolrRequestHandler handler ) {
- String norm = normalize(handlerName);
- if (handler == null) {
- return handlers.remove(norm);
- }
- return handlers.put(norm, handler);
-// return register(handlerName, new PluginRegistry.PluginHolder<>(null, handler));
- }
-
-
- /**
- * Returns an unmodifiable Map containing the registered handlers
- */
- public PluginBag<SolrRequestHandler> getRequestHandlers() {
- return handlers;
- }
-
-
- /**
- * Read solrconfig.xml and register the appropriate handlers
- *
- * This function should <b>only</b> be called from the SolrCore constructor. It is
- * not intended as a public API.
- *
- * While the normal runtime registration contract is that handlers MUST be initialized
- * before they are registered, this function does not do that exactly.
- *
- * This function registers all handlers first and then calls init() for each one.
- *
- * This is OK because this function is only called at startup and there is no chance that
- * a handler could be asked to handle a request before it is initialized.
- *
- * The advantage to this approach is that handlers can know what path they are registered
- * to and what other handlers are available at startup.
- *
- * Handlers will be registered and initialized in the order they appear in solrconfig.xml
- */
-
- void initHandlersFromConfig(SolrConfig config) {
- List<PluginInfo> implicits = core.getImplicitHandlers();
- // use link map so we iterate in the same order
- Map<String, PluginInfo> infoMap= new LinkedHashMap<>();
- //deduping implicit and explicit requesthandlers
- for (PluginInfo info : implicits) infoMap.put(info.name,info);
- for (PluginInfo info : config.getPluginInfos(SolrRequestHandler.class.getName())) infoMap.put(info.name, info);
- ArrayList<PluginInfo> infos = new ArrayList<>(infoMap.values());
-
- List<PluginInfo> modifiedInfos = new ArrayList<>();
- for (PluginInfo info : infos) {
- modifiedInfos.add(applyInitParams(config, info));
- }
- handlers.init(Collections.emptyMap(),core, modifiedInfos);
- handlers.alias(handlers.getDefault(), "");
- log.debug("Registered paths: {}" , StrUtils.join(new ArrayList<>(handlers.keySet()) , ',' ));
- if (handlers.get("") == null && !handlers.alias("/select", "")) {
- if (handlers.get("") == null && !handlers.alias("standard", "")) {
- log.warn("no default request handler is registered (either '/select' or 'standard')");
- }
- }
- }
-
- private PluginInfo applyInitParams(SolrConfig config, PluginInfo info) {
- List<InitParams> ags = new ArrayList<>();
- String p = info.attributes.get(InitParams.TYPE);
- if(p!=null) {
- for (String arg : StrUtils.splitSmart(p, ',')) {
- if(config.getInitParams().containsKey(arg)) ags.add(config.getInitParams().get(arg));
- else log.warn("INVALID paramSet {} in requestHandler {}", arg, info.toString());
- }
- }
- for (InitParams args : config.getInitParams().values())
- if(args.matchPath(info.name)) ags.add(args);
- if(!ags.isEmpty()){
- info = info.copy();
- for (InitParams initParam : ags) {
- initParam.apply(info);
- }
- }
- return info;
- }
-
- public void close() {
- handlers.close();
- }
-}
-
-
-
-
-
-
-
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/0ae21ad0/solr/core/src/java/org/apache/solr/core/RequestParams.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/core/RequestParams.java b/solr/core/src/java/org/apache/solr/core/RequestParams.java
deleted file mode 100644
index fbb2555..0000000
--- a/solr/core/src/java/org/apache/solr/core/RequestParams.java
+++ /dev/null
@@ -1,269 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.solr.core;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.lang.invoke.MethodHandles;
-import java.nio.charset.StandardCharsets;
-import java.util.Collections;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Map;
-
-import com.google.common.collect.ImmutableMap;
-import org.apache.solr.cloud.ZkSolrResourceLoader;
-import org.apache.solr.common.MapSerializable;
-import org.apache.solr.common.SolrException;
-import org.apache.solr.common.cloud.SolrZkClient;
-import org.apache.solr.common.params.MapSolrParams;
-import org.apache.solr.common.util.Utils;
-import org.apache.zookeeper.KeeperException;
-import org.apache.zookeeper.data.Stat;
-import org.noggit.JSONParser;
-import org.noggit.ObjectBuilder;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-import static java.util.Collections.singletonMap;
-import static org.apache.solr.common.util.Utils.getDeepCopy;
-
-/**
- * The class encapsulates the request time parameters . This is immutable and any changes performed
- * returns a copy of the Object with the changed values
- */
-public class RequestParams implements MapSerializable {
- private static final Logger log = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
-
- private final Map data;
- private final Map<String, ParamSet> paramsets = new LinkedHashMap<>();
- private final int znodeVersion;
-
- public RequestParams(Map data, int znodeVersion) {
- if (data == null) data = Collections.EMPTY_MAP;
- this.data = data;
- Map paramsets = (Map) data.get(NAME);
- if (paramsets != null) {
- for (Object o : paramsets.entrySet()) {
- Map.Entry e = (Map.Entry) o;
- if (e.getValue() instanceof Map) {
- Map value = (Map) e.getValue();
- this.paramsets.put((String) e.getKey(), createParamSet(value, 0l));
- }
- }
- }
- this.znodeVersion = znodeVersion;
- }
-
- public static ParamSet createParamSet(Map map, Long version) {
- Map copy = getDeepCopy(map, 3);
- Map meta = (Map) copy.remove("");
- if (meta == null && version != null) {
- meta = Collections.singletonMap("v", version);
- }
- Map invariants = (Map) copy.remove(INVARIANTS);
- Map appends = (Map) copy.remove(APPENDS);
- return new ParamSet(copy, invariants, appends, meta);
- }
-
- /**
- * This converts Lists to arrays of strings. Because Solr expects
- * params to be String[]
- */
- private static Map getMapCopy(Map value) {
- Map copy = new LinkedHashMap<>();
- for (Object o1 : value.entrySet()) {
- Map.Entry entry = (Map.Entry) o1;
- if ("".equals(entry.getKey())) {
- copy.put(entry.getKey(), entry.getValue());
- continue;
- }
- if (entry.getValue() != null) {
- if (entry.getValue() instanceof List) {
- List l = (List) entry.getValue();
- String[] sarr = new String[l.size()];
- for (int i = 0; i < l.size(); i++) {
- if (l.get(i) != null) sarr[i] = String.valueOf(l.get(i));
- }
- copy.put(entry.getKey(), sarr);
- } else {
- copy.put(entry.getKey(), String.valueOf(entry.getValue()));
- }
- } else {
- copy.put(entry.getKey(), entry.getValue());
- }
- }
- return copy;
- }
-
- public ParamSet getParams(String name) {
- return paramsets.get(name);
- }
-
- public VersionedParams getParams(String name, String type) {
- ParamSet paramSet = paramsets.get(name);
- return paramSet == null ? null : paramSet.getParams(type);
- }
-
- public int getZnodeVersion() {
- return znodeVersion;
- }
-
- @Override
- public Map<String, Object> toMap(Map<String, Object> map) {
- return getMapWithVersion(data, znodeVersion);
- }
-
- public static Map<String, Object> getMapWithVersion(Map<String, Object> data, int znodeVersion) {
- Map result = new LinkedHashMap();
- result.put(ConfigOverlay.ZNODEVER, znodeVersion);
- result.putAll(data);
- return result;
- }
-
- public RequestParams setParams(String name, ParamSet paramSet) {
- Map deepCopy = getDeepCopy(data, 3);
- Map p = (Map) deepCopy.get(NAME);
- if (p == null) deepCopy.put(NAME, p = new LinkedHashMap());
- if (paramSet == null) p.remove(name);
- else p.put(name, paramSet.toMap(new LinkedHashMap<>()));
- return new RequestParams(deepCopy, znodeVersion);
- }
-
- public static RequestParams getFreshRequestParams(SolrResourceLoader loader, RequestParams requestParams) {
- if (loader instanceof ZkSolrResourceLoader) {
- ZkSolrResourceLoader resourceLoader = (ZkSolrResourceLoader) loader;
- try {
- Stat stat = resourceLoader.getZkController().getZkClient().exists(resourceLoader.getConfigSetZkPath() + "/" + RequestParams.RESOURCE, null, true);
- log.debug("latest version of {} in ZK is : {}", resourceLoader.getConfigSetZkPath() + "/" + RequestParams.RESOURCE, stat == null ? "" : stat.getVersion());
- if (stat == null) {
- requestParams = new RequestParams(Collections.EMPTY_MAP, -1);
- } else if (requestParams == null || stat.getVersion() > requestParams.getZnodeVersion()) {
- Object[] o = getMapAndVersion(loader, RequestParams.RESOURCE);
- requestParams = new RequestParams((Map) o[0], (Integer) o[1]);
- log.info("request params refreshed to version {}", requestParams.getZnodeVersion());
- }
- } catch (KeeperException | InterruptedException e) {
- SolrZkClient.checkInterrupted(e);
- throw new SolrException(SolrException.ErrorCode.SERVER_ERROR, e);
- }
-
- } else {
- Object[] o = getMapAndVersion(loader, RequestParams.RESOURCE);
- requestParams = new RequestParams((Map) o[0], (Integer) o[1]);
- }
-
- return requestParams;
-
- }
-
-
- private static Object[] getMapAndVersion(SolrResourceLoader loader, String name) {
- try (InputStream in = loader.openResource(name)) {
- int version = 0; //will be always 0 for file based resourceloader
- if (in instanceof ZkSolrResourceLoader.ZkByteArrayInputStream) {
- version = ((ZkSolrResourceLoader.ZkByteArrayInputStream) in).getStat().getVersion();
- log.info("conf resource {} loaded . version : {} ", name, version);
- }
- try {
- Map m = (Map) ObjectBuilder.getVal(new JSONParser(new InputStreamReader(in, StandardCharsets.UTF_8)));
- return new Object[]{m, version};
- } catch (IOException e) {
- throw new SolrException(SolrException.ErrorCode.SERVER_ERROR, "Error parsing conf resource " + name, e);
- }
-
- } catch (IOException e) {
- //no problem no overlay.json file
- return new Object[]{Collections.EMPTY_MAP, -1};
- }
- }
-
-
- public byte[] toByteArray() {
- return Utils.toJSON(data);
- }
-
- public static final String USEPARAM = "useParams";
- public static final String NAME = "params";
- public static final String RESOURCE = "params.json";
- public static final String APPENDS = "_appends_";
- public static final String INVARIANTS = "_invariants_";
-
- public static class ParamSet implements MapSerializable {
- private final Map defaults, appends, invariants;
- Map<String, VersionedParams> paramsMap;
- public final Map meta;
-
- ParamSet(Map defaults, Map invariants, Map appends, Map meta) {
- this.defaults = defaults;
- this.invariants = invariants;
- this.appends = appends;
- ImmutableMap.Builder<String, VersionedParams> builder = ImmutableMap.<String, VersionedParams>builder().put(PluginInfo.DEFAULTS,
- new VersionedParams(defaults, this));
- if (appends != null) builder.put(PluginInfo.APPENDS, new VersionedParams(appends, this));
- if (invariants != null) builder.put(PluginInfo.INVARIANTS, new VersionedParams(invariants, this));
- paramsMap = builder.build();
- this.meta = meta;
- }
-
- public Long getVersion() {
- return meta == null ? Long.valueOf(0l) : (Long) meta.get("v");
- }
-
- @Override
- public Map<String, Object> toMap(Map<String, Object> result) {
- result.putAll(defaults);
- if (appends != null) result.put(APPENDS, appends);
- if (invariants != null) result.put(INVARIANTS, invariants);
- if(meta != null) result.put("", meta);
- return result;
- }
-
-
- public ParamSet update(Map map) {
- ParamSet p = createParamSet(map, null);
- return new ParamSet(
- mergeMaps(getDeepCopy(defaults, 2), p.defaults),
- mergeMaps(getDeepCopy(invariants, 2), p.invariants),
- mergeMaps(getDeepCopy(appends, 2), p.appends),
- mergeMaps(getDeepCopy(meta, 2), singletonMap("v", getVersion() + 1))
- );
- }
-
- private static Map mergeMaps(Map m1, Map m2) {
- if (m1 == null && m2 == null) return null;
- if (m1 == null) return m2;
- if (m2 == null) return m1;
- m1.putAll(m2);
- return m1;
- }
-
- public VersionedParams getParams(String type) {
- return paramsMap.get(type);
- }
- }
-
- public static class VersionedParams extends MapSolrParams {
- final ParamSet paramSet;
-
- public VersionedParams(Map map, ParamSet paramSet) {
- super(getMapCopy(map));
- this.paramSet = paramSet;
- }
- }
-}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/0ae21ad0/solr/core/src/java/org/apache/solr/core/SchemaCodecFactory.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/core/SchemaCodecFactory.java b/solr/core/src/java/org/apache/solr/core/SchemaCodecFactory.java
deleted file mode 100644
index 5adc161..0000000
--- a/solr/core/src/java/org/apache/solr/core/SchemaCodecFactory.java
+++ /dev/null
@@ -1,125 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.solr.core;
-
-import java.lang.invoke.MethodHandles;
-import java.util.Arrays;
-import java.util.Locale;
-
-import org.apache.lucene.codecs.Codec;
-import org.apache.lucene.codecs.DocValuesFormat;
-import org.apache.lucene.codecs.PostingsFormat;
-import org.apache.lucene.codecs.lucene50.Lucene50StoredFieldsFormat.Mode;
-import org.apache.lucene.codecs.lucene80.Lucene80Codec;
-import org.apache.solr.common.SolrException.ErrorCode;
-import org.apache.solr.common.SolrException;
-import org.apache.solr.common.util.NamedList;
-import org.apache.solr.schema.SchemaField;
-import org.apache.solr.util.plugin.SolrCoreAware;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-
-/**
- * Per-field CodecFactory implementation, extends Lucene's
- * and returns postings format implementations according to the
- * schema configuration.
- * <br>
- * Also, a string argument with name <code>compressionMode</code> can be
- * provided to chose between the different compression options for
- * stored fields
- *
- * @lucene.experimental
- */
-public class SchemaCodecFactory extends CodecFactory implements SolrCoreAware {
-
- /**
- * Key to use in init arguments to set the compression mode in the codec.
- */
- public static final String COMPRESSION_MODE = "compressionMode";
-
- public static final Mode SOLR_DEFAULT_COMPRESSION_MODE = Mode.BEST_SPEED;
-
- private static final Logger log = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
-
- private Codec codec;
- private volatile SolrCore core;
-
-
- // TODO: we need to change how solr does this?
- // rather than a string like "Direct" you need to be able to pass parameters
- // and everything to a field in the schema, e.g. we should provide factories for
- // the Lucene's core formats (Memory, Direct, ...) and such.
- //
- // So I think a FieldType should return PostingsFormat, not a String.
- // how it constructs this from the XML... i don't care.
-
- @Override
- public void inform(SolrCore core) {
- this.core = core;
- }
-
- @Override
- public void init(NamedList args) {
- super.init(args);
- assert codec == null;
- String compressionModeStr = (String)args.get(COMPRESSION_MODE);
- Mode compressionMode;
- if (compressionModeStr != null) {
- try {
- compressionMode = Mode.valueOf(compressionModeStr.toUpperCase(Locale.ROOT));
- } catch (IllegalArgumentException e) {
- throw new SolrException(ErrorCode.SERVER_ERROR,
- "Invalid compressionMode: '" + compressionModeStr +
- "'. Value must be one of " + Arrays.toString(Mode.values()));
- }
- log.debug("Using compressionMode: " + compressionMode);
- } else {
- compressionMode = SOLR_DEFAULT_COMPRESSION_MODE;
- log.debug("Using default compressionMode: " + compressionMode);
- }
- codec = new Lucene80Codec(compressionMode) {
- @Override
- public PostingsFormat getPostingsFormatForField(String field) {
- final SchemaField schemaField = core.getLatestSchema().getFieldOrNull(field);
- if (schemaField != null) {
- String postingsFormatName = schemaField.getType().getPostingsFormat();
- if (postingsFormatName != null) {
- return PostingsFormat.forName(postingsFormatName);
- }
- }
- return super.getPostingsFormatForField(field);
- }
- @Override
- public DocValuesFormat getDocValuesFormatForField(String field) {
- final SchemaField schemaField = core.getLatestSchema().getFieldOrNull(field);
- if (schemaField != null) {
- String docValuesFormatName = schemaField.getType().getDocValuesFormat();
- if (docValuesFormatName != null) {
- return DocValuesFormat.forName(docValuesFormatName);
- }
- }
- return super.getDocValuesFormatForField(field);
- }
- };
- }
-
- @Override
- public Codec getCodec() {
- assert core != null : "inform must be called first";
- return codec;
- }
-}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/0ae21ad0/solr/core/src/java/org/apache/solr/core/ShutdownAwareDirectory.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/core/ShutdownAwareDirectory.java b/solr/core/src/java/org/apache/solr/core/ShutdownAwareDirectory.java
deleted file mode 100644
index effe677..0000000
--- a/solr/core/src/java/org/apache/solr/core/ShutdownAwareDirectory.java
+++ /dev/null
@@ -1,30 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.solr.core;
-
-import java.io.IOException;
-
-import org.apache.lucene.store.Directory;
-
-/**
- * {@link CachingDirectoryFactory} will call this method
- * rather than {@link Directory#close()} on shutdown if
- * a Directory implements this interface.
- */
-public interface ShutdownAwareDirectory {
- public void closeOnShutdown() throws IOException;
-}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/0ae21ad0/solr/core/src/java/org/apache/solr/core/SimpleFSDirectoryFactory.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/core/SimpleFSDirectoryFactory.java b/solr/core/src/java/org/apache/solr/core/SimpleFSDirectoryFactory.java
deleted file mode 100644
index 0784d21..0000000
--- a/solr/core/src/java/org/apache/solr/core/SimpleFSDirectoryFactory.java
+++ /dev/null
@@ -1,42 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.solr.core;
-import java.io.File;
-import java.io.IOException;
-
-import org.apache.lucene.store.Directory;
-import org.apache.lucene.store.LockFactory;
-import org.apache.lucene.store.SimpleFSDirectory;
-
-
-/**
- * Factory to instantiate {@link org.apache.lucene.store.SimpleFSDirectory}
- *
- **/
-public class SimpleFSDirectoryFactory extends StandardDirectoryFactory {
-
- @Override
- protected Directory create(String path, LockFactory lockFactory, DirContext dirContext) throws IOException {
- // we pass NoLockFactory, because the real lock factory is set later by injectLockFactory:
- return new SimpleFSDirectory(new File(path).toPath(), lockFactory);
- }
-
- @Override
- public boolean isAbsolute(String path) {
- return new File(path).isAbsolute();
- }
-}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/0ae21ad0/solr/core/src/java/org/apache/solr/core/SimpleTextCodecFactory.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/core/SimpleTextCodecFactory.java b/solr/core/src/java/org/apache/solr/core/SimpleTextCodecFactory.java
deleted file mode 100644
index de0124f..0000000
--- a/solr/core/src/java/org/apache/solr/core/SimpleTextCodecFactory.java
+++ /dev/null
@@ -1,38 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.solr.core;
-
-import org.apache.lucene.codecs.Codec;
-import org.apache.lucene.codecs.simpletext.SimpleTextCodec;
-import org.apache.solr.common.util.NamedList;
-
-public class SimpleTextCodecFactory extends CodecFactory {
- private Codec codec;
-
- @Override
- public void init(NamedList args) {
- super.init(args);
- assert codec == null;
- codec = new SimpleTextCodec();
- }
-
- @Override
- public Codec getCodec() {
- return codec;
- }
-}
http://git-wip-us.apache.org/repos/asf/lucene-solr/blob/0ae21ad0/solr/core/src/java/org/apache/solr/core/SolrConfig.java
----------------------------------------------------------------------
diff --git a/solr/core/src/java/org/apache/solr/core/SolrConfig.java b/solr/core/src/java/org/apache/solr/core/SolrConfig.java
deleted file mode 100644
index fcae44e..0000000
--- a/solr/core/src/java/org/apache/solr/core/SolrConfig.java
+++ /dev/null
@@ -1,963 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-package org.apache.solr.core;
-
-
-import static org.apache.solr.common.params.CommonParams.NAME;
-import static org.apache.solr.common.params.CommonParams.PATH;
-import static org.apache.solr.common.util.Utils.makeMap;
-import static org.apache.solr.core.ConfigOverlay.ZNODEVER;
-import static org.apache.solr.core.SolrConfig.PluginOpts.LAZY;
-import static org.apache.solr.core.SolrConfig.PluginOpts.MULTI_OK;
-import static org.apache.solr.core.SolrConfig.PluginOpts.NOOP;
-import static org.apache.solr.core.SolrConfig.PluginOpts.REQUIRE_CLASS;
-import static org.apache.solr.core.SolrConfig.PluginOpts.REQUIRE_NAME;
-import static org.apache.solr.core.SolrConfig.PluginOpts.REQUIRE_NAME_IN_OVERLAY;
-
-import java.io.IOException;
-import java.io.InputStream;
-import java.io.InputStreamReader;
-import java.lang.invoke.MethodHandles;
-import java.net.MalformedURLException;
-import java.net.URL;
-import java.nio.charset.StandardCharsets;
-import java.nio.file.Path;
-import java.nio.file.Paths;
-import java.util.ArrayList;
-import java.util.Collections;
-import java.util.EnumSet;
-import java.util.HashMap;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Locale;
-import java.util.Map;
-import java.util.Properties;
-import java.util.Set;
-import java.util.UUID;
-import java.util.regex.Matcher;
-import java.util.regex.Pattern;
-
-import javax.xml.parsers.ParserConfigurationException;
-import javax.xml.xpath.XPathConstants;
-
-import org.apache.commons.io.FileUtils;
-import org.apache.lucene.index.IndexDeletionPolicy;
-import org.apache.lucene.search.BooleanQuery;
-import org.apache.lucene.util.Version;
-import org.apache.solr.client.solrj.io.stream.expr.Expressible;
-import org.apache.solr.cloud.RecoveryStrategy;
-import org.apache.solr.cloud.ZkSolrResourceLoader;
-import org.apache.solr.common.MapSerializable;
-import org.apache.solr.common.SolrException;
-import org.apache.solr.common.SolrException.ErrorCode;
-import org.apache.solr.common.util.IOUtils;
-import org.apache.solr.handler.component.SearchComponent;
-import org.apache.solr.request.SolrRequestHandler;
-import org.apache.solr.response.QueryResponseWriter;
-import org.apache.solr.response.transform.TransformerFactory;
-import org.apache.solr.rest.RestManager;
-import org.apache.solr.schema.IndexSchemaFactory;
-import org.apache.solr.search.CacheConfig;
-import org.apache.solr.search.FastLRUCache;
-import org.apache.solr.search.QParserPlugin;
-import org.apache.solr.search.SolrCache;
-import org.apache.solr.search.ValueSourceParser;
-import org.apache.solr.search.stats.StatsCache;
-import org.apache.solr.servlet.SolrRequestParsers;
-import org.apache.solr.spelling.QueryConverter;
-import org.apache.solr.update.SolrIndexConfig;
-import org.apache.solr.update.UpdateLog;
-import org.apache.solr.update.processor.UpdateRequestProcessorChain;
-import org.apache.solr.update.processor.UpdateRequestProcessorFactory;
-import org.apache.solr.util.DOMUtil;
-import org.noggit.JSONParser;
-import org.noggit.ObjectBuilder;
-import org.slf4j.Logger;
-import org.slf4j.LoggerFactory;
-import org.w3c.dom.Node;
-import org.w3c.dom.NodeList;
-import org.xml.sax.InputSource;
-import org.xml.sax.SAXException;
-
-import com.google.common.collect.ImmutableList;
-
-
-/**
- * Provides a static reference to a Config object modeling the main
- * configuration data for a a Solr instance -- typically found in
- * "solrconfig.xml".
- */
-public class SolrConfig extends Config implements MapSerializable {
-
- private static final Logger log = LoggerFactory.getLogger(MethodHandles.lookup().lookupClass());
-
- public static final String DEFAULT_CONF_FILE = "solrconfig.xml";
- private RequestParams requestParams;
-
- public enum PluginOpts {
- MULTI_OK,
- REQUIRE_NAME,
- REQUIRE_NAME_IN_OVERLAY,
- REQUIRE_CLASS,
- LAZY,
- // EnumSet.of and/or EnumSet.copyOf(Collection) are annoying
- // because of type determination
- NOOP
- }
-
- private int multipartUploadLimitKB;
-
- private int formUploadLimitKB;
-
- private boolean enableRemoteStreams;
- private boolean enableStreamBody;
-
- private boolean handleSelect;
-
- private boolean addHttpRequestToContext;
-
- private final SolrRequestParsers solrRequestParsers;
-
- /**
- * Creates a default instance from the solrconfig.xml.
- */
- public SolrConfig()
- throws ParserConfigurationException, IOException, SAXException {
- this((SolrResourceLoader) null, DEFAULT_CONF_FILE, null);
- }
-
- /**
- * Creates a configuration instance from a configuration name.
- * A default resource loader will be created (@see SolrResourceLoader)
- *
- * @param name the configuration name used by the loader
- */
- public SolrConfig(String name)
- throws ParserConfigurationException, IOException, SAXException {
- this((SolrResourceLoader) null, name, null);
- }
-
- /**
- * Creates a configuration instance from a configuration name and stream.
- * A default resource loader will be created (@see SolrResourceLoader).
- * If the stream is null, the resource loader will open the configuration stream.
- * If the stream is not null, no attempt to load the resource will occur (the name is not used).
- *
- * @param name the configuration name
- * @param is the configuration stream
- */
- public SolrConfig(String name, InputSource is)
- throws ParserConfigurationException, IOException, SAXException {
- this((SolrResourceLoader) null, name, is);
- }
-
- /**
- * Creates a configuration instance from an instance directory, configuration name and stream.
- *
- * @param instanceDir the directory used to create the resource loader
- * @param name the configuration name used by the loader if the stream is null
- * @param is the configuration stream
- */
- public SolrConfig(Path instanceDir, String name, InputSource is)
- throws ParserConfigurationException, IOException, SAXException {
- this(new SolrResourceLoader(instanceDir), name, is);
- }
-
- public static SolrConfig readFromResourceLoader(SolrResourceLoader loader, String name) {
- try {
- return new SolrConfig(loader, name, null);
- } catch (Exception e) {
- String resource;
- if (loader instanceof ZkSolrResourceLoader) {
- resource = name;
- } else {
- resource = Paths.get(loader.getConfigDir()).resolve(name).toString();
- }
- throw new SolrException(ErrorCode.SERVER_ERROR, "Error loading solr config from " + resource, e);
- }
- }
-
- /**
- * Creates a configuration instance from a resource loader, a configuration name and a stream.
- * If the stream is null, the resource loader will open the configuration stream.
- * If the stream is not null, no attempt to load the resource will occur (the name is not used).
- *
- * @param loader the resource loader
- * @param name the configuration name
- * @param is the configuration stream
- */
- public SolrConfig(SolrResourceLoader loader, String name, InputSource is)
- throws ParserConfigurationException, IOException, SAXException {
- super(loader, name, is, "/config/");
- getOverlay();//just in case it is not initialized
- getRequestParams();
- initLibs();
- luceneMatchVersion = getLuceneVersion("luceneMatchVersion");
- String indexConfigPrefix;
-
- // Old indexDefaults and mainIndex sections are deprecated and fails fast for luceneMatchVersion=>LUCENE_4_0_0.
- // For older solrconfig.xml's we allow the old sections, but never mixed with the new <indexConfig>
- boolean hasDeprecatedIndexConfig = (getNode("indexDefaults", false) != null) || (getNode("mainIndex", false) != null);
- if (hasDeprecatedIndexConfig) {
- throw new SolrException(ErrorCode.FORBIDDEN, "<indexDefaults> and <mainIndex> configuration sections are discontinued. Use <indexConfig> instead.");
- } else {
- indexConfigPrefix = "indexConfig";
- }
- assertWarnOrFail("The <nrtMode> config has been discontinued and NRT mode is always used by Solr." +
- " This config will be removed in future versions.", getNode(indexConfigPrefix + "/nrtMode", false) == null,
- true
- );
- assertWarnOrFail("Solr no longer supports forceful unlocking via the 'unlockOnStartup' option. "+
- "This is no longer necessary for the default lockType except in situations where "+
- "it would be dangerous and should not be done. For other lockTypes and/or "+
- "directoryFactory options it may also be dangerous and users must resolve "+
- "problematic locks manually.",
- null == getNode(indexConfigPrefix + "/unlockOnStartup", false),
- true // 'fail' in trunk
- );
-
- // Parse indexConfig section, using mainIndex as backup in case old config is used
- indexConfig = new SolrIndexConfig(this, "indexConfig", null);
-
- booleanQueryMaxClauseCount = getInt("query/maxBooleanClauses", BooleanQuery.getMaxClauseCount());
- log.info("Using Lucene MatchVersion: {}", luceneMatchVersion);
-
- // Warn about deprecated / discontinued parameters
- // boolToFilterOptimizer has had no effect since 3.1
- if (get("query/boolTofilterOptimizer", null) != null)
- log.warn("solrconfig.xml: <boolTofilterOptimizer> is currently not implemented and has no effect.");
- if (get("query/HashDocSet", null) != null)
- log.warn("solrconfig.xml: <HashDocSet> is deprecated and no longer recommended used.");
-
-// TODO: Old code - in case somebody wants to re-enable. Also see SolrIndexSearcher#search()
-// filtOptEnabled = getBool("query/boolTofilterOptimizer/@enabled", false);
-// filtOptCacheSize = getInt("query/boolTofilterOptimizer/@cacheSize",32);
-// filtOptThreshold = getFloat("query/boolTofilterOptimizer/@threshold",.05f);
-
- useFilterForSortedQuery = getBool("query/useFilterForSortedQuery", false);
- queryResultWindowSize = Math.max(1, getInt("query/queryResultWindowSize", 1));
- queryResultMaxDocsCached = getInt("query/queryResultMaxDocsCached", Integer.MAX_VALUE);
- enableLazyFieldLoading = getBool("query/enableLazyFieldLoading", false);
-
- useRangeVersionsForPeerSync = getBool("peerSync/useRangeVersions", true);
-
- filterCacheConfig = CacheConfig.getConfig(this, "query/filterCache");
- queryResultCacheConfig = CacheConfig.getConfig(this, "query/queryResultCache");
- documentCacheConfig = CacheConfig.getConfig(this, "query/documentCache");
- CacheConfig conf = CacheConfig.getConfig(this, "query/fieldValueCache");
- if (conf == null) {
- Map<String, String> args = new HashMap<>();
- args.put(NAME, "fieldValueCache");
- args.put("size", "10000");
- args.put("initialSize", "10");
- args.put("showItems", "-1");
- conf = new CacheConfig(FastLRUCache.class, args, null);
- }
- fieldValueCacheConfig = conf;
- useColdSearcher = getBool("query/useColdSearcher", false);
- dataDir = get("dataDir", null);
- if (dataDir != null && dataDir.length() == 0) dataDir = null;
-
-
- org.apache.solr.search.SolrIndexSearcher.initRegenerators(this);
-
- hashSetInverseLoadFactor = 1.0f / getFloat("//HashDocSet/@loadFactor", 0.75f);
- hashDocSetMaxSize = getInt("//HashDocSet/@maxSize", 3000);
-
- if (get("jmx", null) != null) {
- log.warn("solrconfig.xml: <jmx> is no longer supported, use solr.xml:/metrics/reporter section instead");
- }
-
- httpCachingConfig = new HttpCachingConfig(this);
-
- maxWarmingSearchers = getInt("query/maxWarmingSearchers", 1);
- slowQueryThresholdMillis = getInt("query/slowQueryThresholdMillis", -1);
- for (SolrPluginInfo plugin : plugins) loadPluginInfo(plugin);
-
- Map<String, CacheConfig> userCacheConfigs = CacheConfig.getMultipleConfigs(this, "query/cache");
- List<PluginInfo> caches = getPluginInfos(SolrCache.class.getName());
- if (!caches.isEmpty()) {
- for (PluginInfo c : caches) {
- userCacheConfigs.put(c.name, CacheConfig.getConfig(this, "cache", c.attributes, null));
- }
- }
- this.userCacheConfigs = Collections.unmodifiableMap(userCacheConfigs);
-
- updateHandlerInfo = loadUpdatehandlerInfo();
-
- multipartUploadLimitKB = getInt(
- "requestDispatcher/requestParsers/@multipartUploadLimitInKB", Integer.MAX_VALUE);
- if (multipartUploadLimitKB == -1) multipartUploadLimitKB = Integer.MAX_VALUE;
-
- formUploadLimitKB = getInt(
- "requestDispatcher/requestParsers/@formdataUploadLimitInKB", Integer.MAX_VALUE);
- if (formUploadLimitKB == -1) formUploadLimitKB = Integer.MAX_VALUE;
-
- enableRemoteStreams = getBool(
- "requestDispatcher/requestParsers/@enableRemoteStreaming", false);
-
- enableStreamBody = getBool(
- "requestDispatcher/requestParsers/@enableStreamBody", false);
-
- handleSelect = getBool(
- "requestDispatcher/@handleSelect", !luceneMatchVersion.onOrAfter(Version.LUCENE_7_0_0));
-
- addHttpRequestToContext = getBool(
- "requestDispatcher/requestParsers/@addHttpRequestToContext", false);
-
- List<PluginInfo> argsInfos = getPluginInfos(InitParams.class.getName());
- if (argsInfos != null) {
- Map<String, InitParams> argsMap = new HashMap<>();
- for (PluginInfo p : argsInfos) {
- InitParams args = new InitParams(p);
- argsMap.put(args.name == null ? String.valueOf(args.hashCode()) : args.name, args);
- }
- this.initParams = Collections.unmodifiableMap(argsMap);
-
- }
-
- solrRequestParsers = new SolrRequestParsers(this);
- log.debug("Loaded SolrConfig: {}", name);
- }
-
- public static final List<SolrPluginInfo> plugins = ImmutableList.<SolrPluginInfo>builder()
- .add(new SolrPluginInfo(SolrRequestHandler.class, SolrRequestHandler.TYPE, REQUIRE_NAME, REQUIRE_CLASS, MULTI_OK, LAZY))
- .add(new SolrPluginInfo(QParserPlugin.class, "queryParser", REQUIRE_NAME, REQUIRE_CLASS, MULTI_OK))
- .add(new SolrPluginInfo(Expressible.class, "expressible", REQUIRE_NAME, REQUIRE_CLASS, MULTI_OK))
- .add(new SolrPluginInfo(QueryResponseWriter.class, "queryResponseWriter", REQUIRE_NAME, REQUIRE_CLASS, MULTI_OK, LAZY))
- .add(new SolrPluginInfo(ValueSourceParser.class, "valueSourceParser", REQUIRE_NAME, REQUIRE_CLASS, MULTI_OK))
- .add(new SolrPluginInfo(TransformerFactory.class, "transformer", REQUIRE_NAME, REQUIRE_CLASS, MULTI_OK))
- .add(new SolrPluginInfo(SearchComponent.class, "searchComponent", REQUIRE_NAME, REQUIRE_CLASS, MULTI_OK))
- .add(new SolrPluginInfo(UpdateRequestProcessorFactory.class, "updateProcessor", REQUIRE_NAME, REQUIRE_CLASS, MULTI_OK))
- .add(new SolrPluginInfo(SolrCache.class, "cache", REQUIRE_NAME, REQUIRE_CLASS, MULTI_OK))
- // TODO: WTF is up with queryConverter???
- // it apparently *only* works as a singleton? - SOLR-4304
- // and even then -- only if there is a single SpellCheckComponent
- // because of queryConverter.setIndexAnalyzer
- .add(new SolrPluginInfo(QueryConverter.class, "queryConverter", REQUIRE_NAME, REQUIRE_CLASS))
- .add(new SolrPluginInfo(PluginBag.RuntimeLib.class, "runtimeLib", REQUIRE_NAME, MULTI_OK))
- // this is hackish, since it picks up all SolrEventListeners,
- // regardless of when/how/why they are used (or even if they are
- // declared outside of the appropriate context) but there's no nice
- // way around that in the PluginInfo framework
- .add(new SolrPluginInfo(InitParams.class, InitParams.TYPE, MULTI_OK, REQUIRE_NAME_IN_OVERLAY))
- .add(new SolrPluginInfo(SolrEventListener.class, "//listener", REQUIRE_CLASS, MULTI_OK, REQUIRE_NAME_IN_OVERLAY))
-
- .add(new SolrPluginInfo(DirectoryFactory.class, "directoryFactory", REQUIRE_CLASS))
- .add(new SolrPluginInfo(RecoveryStrategy.Builder.class, "recoveryStrategy"))
- .add(new SolrPluginInfo(IndexDeletionPolicy.class, "indexConfig/deletionPolicy", REQUIRE_CLASS))
- .add(new SolrPluginInfo(CodecFactory.class, "codecFactory", REQUIRE_CLASS))
- .add(new SolrPluginInfo(IndexReaderFactory.class, "indexReaderFactory", REQUIRE_CLASS))
- .add(new SolrPluginInfo(UpdateRequestProcessorChain.class, "updateRequestProcessorChain", MULTI_OK))
- .add(new SolrPluginInfo(UpdateLog.class, "updateHandler/updateLog"))
- .add(new SolrPluginInfo(IndexSchemaFactory.class, "schemaFactory", REQUIRE_CLASS))
- .add(new SolrPluginInfo(RestManager.class, "restManager"))
- .add(new SolrPluginInfo(StatsCache.class, "statsCache", REQUIRE_CLASS))
- .build();
- public static final Map<String, SolrPluginInfo> classVsSolrPluginInfo;
-
- static {
- // Raise the Lucene static limit so we can control this with higher granularity. See SOLR-10921
- BooleanQuery.setMaxClauseCount(Integer.MAX_VALUE-1);
-
- Map<String, SolrPluginInfo> map = new HashMap<>();
- for (SolrPluginInfo plugin : plugins) map.put(plugin.clazz.getName(), plugin);
- classVsSolrPluginInfo = Collections.unmodifiableMap(map);
- }
-
- {
- // non-static setMaxClauseCount because the test framework sometimes reverts the value on us and
- // the static setting above is only executed once. This re-sets the value every time a SolrConfig
- // object is created. See SOLR-10921
- BooleanQuery.setMaxClauseCount(Integer.MAX_VALUE-1);
- }
-
-
- public static class SolrPluginInfo {
-
- public final Class clazz;
- public final String tag;
- public final Set<PluginOpts> options;
-
-
- private SolrPluginInfo(Class clz, String tag, PluginOpts... opts) {
- this.clazz = clz;
- this.tag = tag;
- this.options = opts == null ? Collections.EMPTY_SET : EnumSet.of(NOOP, opts);
- }
-
- public String getCleanTag() {
- return tag.replaceAll("/", "");
- }
-
- public String getTagCleanLower() {
- return getCleanTag().toLowerCase(Locale.ROOT);
-
- }
- }
-
- public static ConfigOverlay getConfigOverlay(SolrResourceLoader loader) {
- InputStream in = null;
- InputStreamReader isr = null;
- try {
- try {
- in = loader.openResource(ConfigOverlay.RESOURCE_NAME);
- } catch (IOException e) {
- // TODO: we should be explicitly looking for file not found exceptions
- // and logging if it's not the expected IOException
- // hopefully no problem, assume no overlay.json file
- return new ConfigOverlay(Collections.EMPTY_MAP, -1);
- }
-
- int version = 0; // will be always 0 for file based resourceLoader
- if (in instanceof ZkSolrResourceLoader.ZkByteArrayInputStream) {
- version = ((ZkSolrResourceLoader.ZkByteArrayInputStream) in).getStat().getVersion();
- log.debug("Config overlay loaded. version : {} ", version);
- }
- isr = new InputStreamReader(in, StandardCharsets.UTF_8);
- Map m = (Map) ObjectBuilder.getVal(new JSONParser(isr));
- return new ConfigOverlay(m, version);
- } catch (Exception e) {
- throw new SolrException(ErrorCode.SERVER_ERROR, "Error reading config overlay", e);
- } finally {
- IOUtils.closeQuietly(isr);
- IOUtils.closeQuietly(in);
- }
- }
-
- private Map<String, InitParams> initParams = Collections.emptyMap();
-
- public Map<String, InitParams> getInitParams() {
- return initParams;
- }
-
- protected UpdateHandlerInfo loadUpdatehandlerInfo() {
- return new UpdateHandlerInfo(get("updateHandler/@class", null),
- getInt("updateHandler/autoCommit/maxDocs", -1),
- getInt("updateHandler/autoCommit/maxTime", -1),
- convertHeapOptionStyleConfigStringToBytes(get("updateHandler/autoCommit/maxSize", "")),
- getBool("updateHandler/indexWriter/closeWaitsForMerges", true),
- getBool("updateHandler/autoCommit/openSearcher", true),
- getInt("updateHandler/autoSoftCommit/maxDocs", -1),
- getInt("updateHandler/autoSoftCommit/maxTime", -1),
- getBool("updateHandler/commitWithin/softCommit", true));
- }
-
- /**
- * Converts a Java heap option-like config string to bytes. Valid suffixes are: 'k', 'm', 'g'
- * (case insensitive). If there is no suffix, the default unit is bytes.
- * For example, 50k = 50KB, 20m = 20MB, 4g = 4GB, 300 = 300 bytes
- * @param configStr the config setting to parse
- * @return the size, in bytes. -1 if the given config string is empty
- */
- protected static long convertHeapOptionStyleConfigStringToBytes(String configStr) {
- if (configStr.isEmpty()) {
- return -1;
- }
- long multiplier = 1;
- String numericValueStr = configStr;
- char suffix = Character.toLowerCase(configStr.charAt(configStr.length() - 1));
- if (Character.isLetter(suffix)) {
- if (suffix == 'k') {
- multiplier = FileUtils.ONE_KB;
- }
- else if (suffix == 'm') {
- multiplier = FileUtils.ONE_MB;
- }
- else if (suffix == 'g') {
- multiplier = FileUtils.ONE_GB;
- } else {
- throw new RuntimeException("Invalid suffix. Valid suffixes are 'k' (KB), 'm' (MB), 'g' (G). "
- + "No suffix means the amount is in bytes. ");
- }
- numericValueStr = configStr.substring(0, configStr.length() - 1);
- }
- try {
- return Long.parseLong(numericValueStr) * multiplier;
- } catch (NumberFormatException e) {
- throw new RuntimeException("Invalid format. The config setting should be a long with an "
- + "optional letter suffix. Valid suffixes are 'k' (KB), 'm' (MB), 'g' (G). "
- + "No suffix means the amount is in bytes.");
- }
- }
-
- private void loadPluginInfo(SolrPluginInfo pluginInfo) {
- boolean requireName = pluginInfo.options.contains(REQUIRE_NAME);
- boolean requireClass = pluginInfo.options.contains(REQUIRE_CLASS);
-
- List<PluginInfo> result = readPluginInfos(pluginInfo.tag, requireName, requireClass);
-
- if (1 < result.size() && !pluginInfo.options.contains(MULTI_OK)) {
- throw new SolrException
- (SolrException.ErrorCode.SERVER_ERROR,
- "Found " + result.size() + " configuration sections when at most "
- + "1 is allowed matching expression: " + pluginInfo.getCleanTag());
- }
- if (!result.isEmpty()) pluginStore.put(pluginInfo.clazz.getName(), result);
- }
-
- public List<PluginInfo> readPluginInfos(String tag, boolean requireName, boolean requireClass) {
- ArrayList<PluginInfo> result = new ArrayList<>();
- NodeList nodes = (NodeList) evaluate(tag, XPathConstants.NODESET);
- for (int i = 0; i < nodes.getLength(); i++) {
- PluginInfo pluginInfo = new PluginInfo(nodes.item(i), "[solrconfig.xml] " + tag, requireName, requireClass);
- if (pluginInfo.isEnabled()) result.add(pluginInfo);
- }
- return result;
- }
-
- public SolrRequestParsers getRequestParsers() {
- return solrRequestParsers;
- }
-
- /* The set of materialized parameters: */
- public final int booleanQueryMaxClauseCount;
- // SolrIndexSearcher - nutch optimizer -- Disabled since 3.1
-// public final boolean filtOptEnabled;
-// public final int filtOptCacheSize;
-// public final float filtOptThreshold;
- // SolrIndexSearcher - caches configurations
- public final CacheConfig filterCacheConfig;
- public final CacheConfig queryResultCacheConfig;
- public final CacheConfig documentCacheConfig;
- public final CacheConfig fieldValueCacheConfig;
- public final Map<String, CacheConfig> userCacheConfigs;
- // SolrIndexSearcher - more...
- public final boolean useFilterForSortedQuery;
- public final int queryResultWindowSize;
- public final int queryResultMaxDocsCached;
- public final boolean enableLazyFieldLoading;
-
- public final boolean useRangeVersionsForPeerSync;
-
- // DocSet
- public final float hashSetInverseLoadFactor;
- public final int hashDocSetMaxSize;
- // IndexConfig settings
- public final SolrIndexConfig indexConfig;
-
- protected UpdateHandlerInfo updateHandlerInfo;
-
- private Map<String, List<PluginInfo>> pluginStore = new LinkedHashMap<>();
-
- public final int maxWarmingSearchers;
- public final boolean useColdSearcher;
- public final Version luceneMatchVersion;
- protected String dataDir;
- public final int slowQueryThresholdMillis; // threshold above which a query is considered slow
-
- private final HttpCachingConfig httpCachingConfig;
-
- public HttpCachingConfig getHttpCachingConfig() {
- return httpCachingConfig;
- }
-
- public static class HttpCachingConfig implements MapSerializable {
-
- /**
- * config xpath prefix for getting HTTP Caching options
- */
- private final static String CACHE_PRE
- = "requestDispatcher/httpCaching/";
-
- /**
- * For extracting Expires "ttl" from <cacheControl> config
- */
- private final static Pattern MAX_AGE
- = Pattern.compile("\\bmax-age=(\\d+)");
-
- @Override
- public Map<String, Object> toMap(Map<String, Object> map) {
- return makeMap("never304", never304,
- "etagSeed", etagSeed,
- "lastModFrom", lastModFrom.name().toLowerCase(Locale.ROOT),
- "cacheControl", cacheControlHeader);
- }
-
- public static enum LastModFrom {
- OPENTIME, DIRLASTMOD, BOGUS;
-
- /**
- * Input must not be null
- */
- public static LastModFrom parse(final String s) {
- try {
- return valueOf(s.toUpperCase(Locale.ROOT));
- } catch (Exception e) {
- log.warn("Unrecognized value for lastModFrom: " + s, e);
- return BOGUS;
- }
- }
- }
-
- private final boolean never304;
- private final String etagSeed;
- private final String cacheControlHeader;
- private final Long maxAge;
- private final LastModFrom lastModFrom;
-
- private HttpCachingConfig(SolrConfig conf) {
-
- never304 = conf.getBool(CACHE_PRE + "@never304", false);
-
- etagSeed = conf.get(CACHE_PRE + "@etagSeed", "Solr");
-
-
- lastModFrom = LastModFrom.parse(conf.get(CACHE_PRE + "@lastModFrom",
- "openTime"));
-
- cacheControlHeader = conf.get(CACHE_PRE + "cacheControl", null);
-
- Long tmp = null; // maxAge
- if (null != cacheControlHeader) {
- try {
- final Matcher ttlMatcher = MAX_AGE.matcher(cacheControlHeader);
- final String ttlStr = ttlMatcher.find() ? ttlMatcher.group(1) : null;
- tmp = (null != ttlStr && !"".equals(ttlStr))
- ? Long.valueOf(ttlStr)
- : null;
- } catch (Exception e) {
- log.warn("Ignoring exception while attempting to " +
- "extract max-age from cacheControl config: " +
- cacheControlHeader, e);
- }
- }
- maxAge = tmp;
-
- }
-
- public boolean isNever304() {
- return never304;
- }
-
- public String getEtagSeed() {
- return etagSeed;
- }
-
- /**
- * null if no Cache-Control header
- */
- public String getCacheControlHeader() {
- return cacheControlHeader;
- }
-
- /**
- * null if no max age limitation
- */
- public Long getMaxAge() {
- return maxAge;
- }
-
- public LastModFrom getLastModFrom() {
- return lastModFrom;
- }
- }
-
- public static class UpdateHandlerInfo implements MapSerializable {
- public final String className;
- public final int autoCommmitMaxDocs, autoCommmitMaxTime,
- autoSoftCommmitMaxDocs, autoSoftCommmitMaxTime;
- public final long autoCommitMaxSizeBytes;
- public final boolean indexWriterCloseWaitsForMerges;
- public final boolean openSearcher; // is opening a new searcher part of hard autocommit?
- public final boolean commitWithinSoftCommit;
-
- /**
- * @param autoCommmitMaxDocs set -1 as default
- * @param autoCommmitMaxTime set -1 as default
- * @param autoCommitMaxSize set -1 as default
- */
- public UpdateHandlerInfo(String className, int autoCommmitMaxDocs, int autoCommmitMaxTime, long autoCommitMaxSize, boolean indexWriterCloseWaitsForMerges, boolean openSearcher,
- int autoSoftCommmitMaxDocs, int autoSoftCommmitMaxTime, boolean commitWithinSoftCommit) {
- this.className = className;
- this.autoCommmitMaxDocs = autoCommmitMaxDocs;
- this.autoCommmitMaxTime = autoCommmitMaxTime;
- this.autoCommitMaxSizeBytes = autoCommitMaxSize;
- this.indexWriterCloseWaitsForMerges = indexWriterCloseWaitsForMerges;
- this.openSearcher = openSearcher;
-
- this.autoSoftCommmitMaxDocs = autoSoftCommmitMaxDocs;
- this.autoSoftCommmitMaxTime = autoSoftCommmitMaxTime;
-
- this.commitWithinSoftCommit = commitWithinSoftCommit;
- }
-
-
- @Override
- public Map<String, Object> toMap(Map<String, Object> map) {
- LinkedHashMap result = new LinkedHashMap();
- result.put("indexWriter", makeMap("closeWaitsForMerges", indexWriterCloseWaitsForMerges));
- result.put("commitWithin", makeMap("softCommit", commitWithinSoftCommit));
- result.put("autoCommit", makeMap(
- "maxDocs", autoCommmitMaxDocs,
- "maxTime", autoCommmitMaxTime,
- "openSearcher", openSearcher
- ));
- result.put("autoSoftCommit",
- makeMap("maxDocs", autoSoftCommmitMaxDocs,
- "maxTime", autoSoftCommmitMaxTime));
- return result;
- }
- }
-
-// public Map<String, List<PluginInfo>> getUpdateProcessorChainInfo() { return updateProcessorChainInfo; }
-
- public UpdateHandlerInfo getUpdateHandlerInfo() {
- return updateHandlerInfo;
- }
-
- public String getDataDir() {
- return dataDir;
- }
-
- /**
- * SolrConfig keeps a repository of plugins by the type. The known interfaces are the types.
- *
- * @param type The key is FQN of the plugin class there are a few known types : SolrFormatter, SolrFragmenter
- * SolrRequestHandler,QParserPlugin, QueryResponseWriter,ValueSourceParser,
- * SearchComponent, QueryConverter, SolrEventListener, DirectoryFactory,
- * IndexDeletionPolicy, IndexReaderFactory, {@link TransformerFactory}
- */
- public List<PluginInfo> getPluginInfos(String type) {
- List<PluginInfo> result = pluginStore.get(type);
- SolrPluginInfo info = classVsSolrPluginInfo.get(type);
- if (info != null &&
- (info.options.contains(REQUIRE_NAME) || info.options.contains(REQUIRE_NAME_IN_OVERLAY))) {
- Map<String, Map> infos = overlay.getNamedPlugins(info.getCleanTag());
- if (!infos.isEmpty()) {
- LinkedHashMap<String, PluginInfo> map = new LinkedHashMap<>();
- if (result != null) for (PluginInfo pluginInfo : result) {
- //just create a UUID for the time being so that map key is not null
- String name = pluginInfo.name == null ?
- UUID.randomUUID().toString().toLowerCase(Locale.ROOT) :
- pluginInfo.name;
- map.put(name, pluginInfo);
- }
- for (Map.Entry<String, Map> e : infos.entrySet()) {
- map.put(e.getKey(), new PluginInfo(info.getCleanTag(), e.getValue()));
- }
- result = new ArrayList<>(map.values());
- }
- }
- return result == null ? Collections.<PluginInfo>emptyList() : result;
- }
-
- public PluginInfo getPluginInfo(String type) {
- List<PluginInfo> result = pluginStore.get(type);
- if (result == null || result.isEmpty()) {
- return null;
- }
- if (1 == result.size()) {
- return result.get(0);
- }
-
- throw new SolrException(SolrException.ErrorCode.SERVER_ERROR,
- "Multiple plugins configured for type: " + type);
- }
-
- private void initLibs() {
- NodeList nodes = (NodeList) evaluate("lib", XPathConstants.NODESET);
- if (nodes == null || nodes.getLength() == 0) return;
-
- log.debug("Adding specified lib dirs to ClassLoader");
- SolrResourceLoader loader = getResourceLoader();
- List<URL> urls = new ArrayList<>();
-
- for (int i = 0; i < nodes.getLength(); i++) {
- Node node = nodes.item(i);
- String baseDir = DOMUtil.getAttr(node, "dir");
- String path = DOMUtil.getAttr(node, PATH);
- if (null != baseDir) {
- // :TODO: add support for a simpler 'glob' mutually exclusive of regex
- Path dir = loader.getInstancePath().resolve(baseDir);
- String regex = DOMUtil.getAttr(node, "regex");
- try {
- if (regex == null)
- urls.addAll(SolrResourceLoader.getURLs(dir));
- else
- urls.addAll(SolrResourceLoader.getFilteredURLs(dir, regex));
- } catch (IOException e) {
- log.warn("Couldn't add files from {} filtered by {} to classpath: {}", dir, regex, e.getMessage());
- }
- } else if (null != path) {
- final Path dir = loader.getInstancePath().resolve(path);
- try {
- urls.add(dir.toUri().toURL());
- } catch (MalformedURLException e) {
- log.warn("Couldn't add file {} to classpath: {}", dir, e.getMessage());
- }
- } else {
- throw new RuntimeException("lib: missing mandatory attributes: 'dir' or 'path'");
- }
- }
-
- if (urls.size() > 0) {
- loader.addToClassLoader(urls);
- loader.reloadLuceneSPI();
- }
- }
-
- public int getMultipartUploadLimitKB() {
- return multipartUploadLimitKB;
- }
-
- public int getFormUploadLimitKB() {
- return formUploadLimitKB;
- }
-
- public boolean isHandleSelect() {
- return handleSelect;
- }
-
- public boolean isAddHttpRequestToContext() {
- return addHttpRequestToContext;
- }
-
- public boolean isEnableRemoteStreams() {
- return enableRemoteStreams;
- }
-
- public boolean isEnableStreamBody() {
- return enableStreamBody;
- }
-
- @Override
- public int getInt(String path) {
- return getInt(path, 0);
- }
-
- @Override
- public int getInt(String path, int def) {
- Object val = overlay.getXPathProperty(path);
- if (val != null) return Integer.parseInt(val.toString());
- return super.getInt(path, def);
- }
-
- @Override
- public boolean getBool(String path, boolean def) {
- Object val = overlay.getXPathProperty(path);
- if (val != null) return Boolean.parseBoolean(val.toString());
- return super.getBool(path, def);
- }
-
- @Override
- public String get(String path) {
- Object val = overlay.getXPathProperty(path, true);
- return val != null ? val.toString() : super.get(path);
- }
-
- @Override
- public String get(String path, String def) {
- Object val = overlay.getXPathProperty(path, true);
- return val != null ? val.toString() : super.get(path, def);
-
- }
-
- @Override
- public Map<String, Object> toMap(Map<String, Object> result) {
- if (getZnodeVersion() > -1) result.put(ZNODEVER, getZnodeVersion());
- result.put("luceneMatchVersion", luceneMatchVersion);
- result.put("updateHandler", getUpdateHandlerInfo());
- Map m = new LinkedHashMap();
- result.put("query", m);
- m.put("useFilterForSortedQuery", useFilterForSortedQuery);
- m.put("queryResultWindowSize", queryResultWindowSize);
- m.put("queryResultMaxDocsCached", queryResultMaxDocsCached);
- m.put("enableLazyFieldLoading", enableLazyFieldLoading);
- m.put("maxBooleanClauses", booleanQueryMaxClauseCount);
- for (SolrPluginInfo plugin : plugins) {
- List<PluginInfo> infos = getPluginInfos(plugin.clazz.getName());
- if (infos == null || infos.isEmpty()) continue;
- String tag = plugin.getCleanTag();
- tag = tag.replace("/", "");
- if (plugin.options.contains(PluginOpts.REQUIRE_NAME)) {
- LinkedHashMap items = new LinkedHashMap();
- for (PluginInfo info : infos) items.put(info.name, info);
- for (Map.Entry e : overlay.getNamedPlugins(plugin.tag).entrySet()) items.put(e.getKey(), e.getValue());
- result.put(tag, items);
- } else {
- if (plugin.options.contains(MULTI_OK)) {
- ArrayList<MapSerializable> l = new ArrayList<>();
- for (PluginInfo info : infos) l.add(info);
- result.put(tag, l);
- } else {
- result.put(tag, infos.get(0));
- }
-
- }
-
- }
-
-
- addCacheConfig(m, filterCacheConfig, queryResultCacheConfig, documentCacheConfig, fieldValueCacheConfig);
- m = new LinkedHashMap();
- result.put("requestDispatcher", m);
- m.put("handleSelect", handleSelect);
- if (httpCachingConfig != null) m.put("httpCaching", httpCachingConfig);
- m.put("requestParsers", makeMap("multipartUploadLimitKB", multipartUploadLimitKB,
- "formUploadLimitKB", formUploadLimitKB,
- "addHttpRequestToContext", addHttpRequestToContext));
- if (indexConfig != null) result.put("indexConfig", indexConfig);
-
- m = new LinkedHashMap();
- result.put("peerSync", m);
- m.put("useRangeVersions", useRangeVersionsForPeerSync);
-
- //TODO there is more to add
-
- return result;
- }
-
- private void addCacheConfig(Map queryMap, CacheConfig... cache) {
- if (cache == null) return;
- for (CacheConfig config : cache) if (config != null) queryMap.put(config.getNodeName(), config);
-
- }
-
- @Override
- protected Properties getSubstituteProperties() {
- Map<String, Object> p = getOverlay().getUserProps();
- if (p == null || p.isEmpty()) return super.getSubstituteProperties();
- Properties result = new Properties(super.getSubstituteProperties());
- result.putAll(p);
- return result;
- }
-
- private ConfigOverlay overlay;
-
- public ConfigOverlay getOverlay() {
- if (overlay == null) {
- overlay = getConfigOverlay(getResourceLoader());
- }
- return overlay;
- }
-
- public RequestParams getRequestParams() {
- if (requestParams == null) {
- return refreshRequestParams();
- }
- return requestParams;
- }
-
-
- public RequestParams refreshRequestParams() {
- requestParams = RequestParams.getFreshRequestParams(getResourceLoader(), requestParams);
- log.debug("current version of requestparams : {}", requestParams.getZnodeVersion());
- return requestParams;
- }
-
-}