Commit 7cf19213 by skoritala Committed by Sarath Subramanian

ATLAS-3388 Re-use SOLR client for performance improvements.

parent 0d5c2229
...@@ -54,6 +54,7 @@ import org.apache.http.HttpException; ...@@ -54,6 +54,7 @@ import org.apache.http.HttpException;
import org.apache.http.HttpRequest; import org.apache.http.HttpRequest;
import org.apache.http.HttpRequestInterceptor; import org.apache.http.HttpRequestInterceptor;
import org.apache.http.client.HttpClient; import org.apache.http.client.HttpClient;
import org.apache.http.client.utils.HttpClientUtils;
import org.apache.http.entity.BufferedHttpEntity; import org.apache.http.entity.BufferedHttpEntity;
import org.apache.http.impl.auth.KerberosScheme; import org.apache.http.impl.auth.KerberosScheme;
import org.apache.http.protocol.HttpContext; import org.apache.http.protocol.HttpContext;
...@@ -139,7 +140,7 @@ public class Solr6Index implements IndexProvider { ...@@ -139,7 +140,7 @@ public class Solr6Index implements IndexProvider {
private static final char CHROOT_START_CHAR = '/'; private static final char CHROOT_START_CHAR = '/';
private static Solr6Index instance = null; private static Solr6Index instance = null;
public static final ConfigOption<Boolean> CREATE_SOLR_CLIENT_PER_REQUEST = new ConfigOption(SOLR_NS, "create-client-per-request", "when false, allows the sharing of solr client across other components.", org.janusgraph.diskstorage.configuration.ConfigOption.Type.LOCAL, true); public static final ConfigOption<Boolean> CREATE_SOLR_CLIENT_PER_REQUEST = new ConfigOption(SOLR_NS, "create-client-per-request", "when false, allows the sharing of solr client across other components.", org.janusgraph.diskstorage.configuration.ConfigOption.Type.LOCAL, false);
private enum Mode { private enum Mode {
HTTP, CLOUD; HTTP, CLOUD;
...@@ -251,6 +252,9 @@ public class Solr6Index implements IndexProvider { ...@@ -251,6 +252,9 @@ public class Solr6Index implements IndexProvider {
} }
private SolrClient createSolrClient() { private SolrClient createSolrClient() {
if(logger.isDebugEnabled()) {
logger.debug("HttpClientBuilder = {}", HttpClientUtil.getHttpClientBuilder(), new Exception());
}
final ModifiableSolrParams clientParams = new ModifiableSolrParams(); final ModifiableSolrParams clientParams = new ModifiableSolrParams();
SolrClient solrClient = null; SolrClient solrClient = null;
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment