org.apache.solr.client.solrj.request.QueryRequest.setPath()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(5.5k)|赞(0)|评价(0)|浏览(110)

本文整理了Java中org.apache.solr.client.solrj.request.QueryRequest.setPath方法的一些代码示例,展示了QueryRequest.setPath的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryRequest.setPath方法的具体详情如下:
包路径:org.apache.solr.client.solrj.request.QueryRequest
类名称:QueryRequest
方法名:setPath

QueryRequest.setPath介绍

暂无

代码示例

代码示例来源:origin: apache/metron

public QueryRequest getListCollectionsRequest() {
  ModifiableSolrParams params = new ModifiableSolrParams();
  params.set(SolrConstants.REQUEST_ACTION, CollectionParams.CollectionAction.LIST.name());
  QueryRequest request = new QueryRequest(params);
  request.setPath(SolrConstants.REQUEST_COLLECTIONS_PATH);
  return request;
 }
}

代码示例来源:origin: apache/metron

public QueryRequest getCreateCollectionsRequest(String name, int numShards, int replicationFactor) {
 ModifiableSolrParams params = new ModifiableSolrParams();
 params.set(SolrConstants.REQUEST_ACTION, CollectionParams.CollectionAction.CREATE.name());
 params.set(SolrConstants.REQUEST_NAME, name);
 params.set(SolrConstants.REQUEST_NUM_SHARDS, numShards);
 params.set(SolrConstants.REQUEST_REPLICATION_FACTOR, replicationFactor);
 params.set(SolrConstants.REQUEST_COLLECTION_CONFIG_NAME, name);
 QueryRequest request = new QueryRequest(params);
 request.setPath(SolrConstants.REQUEST_COLLECTIONS_PATH);
 return request;
}

代码示例来源:origin: org.apache.solr/solr-solrj

private static Set<String> fetchLiveNodes(SolrClient client) throws Exception {
 ModifiableSolrParams params = new ModifiableSolrParams();
 params.set("action", "CLUSTERSTATUS");
 QueryRequest request = new QueryRequest(params);
 request.setPath("/admin/collections");
 NamedList cluster = (SimpleOrderedMap) client.request(request).get("cluster");
 Set<String> liveNodes = new HashSet((List<String>)(cluster.get("live_nodes")));
 return liveNodes;
}

代码示例来源:origin: org.apache.solr/solr-test-framework

params.set("name", testCollectionName);
QueryRequest request = new QueryRequest(params);
request.setPath("/admin/collections");
client.request(request);
Thread.sleep(2000); // reload can take a short while

代码示例来源:origin: org.apache.solr/solr-solrj

public static JSONTupleStream create(SolrClient server, SolrParams requestParams) throws IOException, SolrServerException {
 String p = requestParams.get("qt");
 if(p != null) {
  ModifiableSolrParams modifiableSolrParams = (ModifiableSolrParams) requestParams;
  modifiableSolrParams.remove("qt");
 }
 QueryRequest query = new QueryRequest( requestParams );
 query.setPath(p);
 query.setResponseParser(new InputStreamResponseParser("json"));
 query.setMethod(SolrRequest.METHOD.POST);
 NamedList<Object> genericResponse = server.request(query);
 InputStream stream = (InputStream)genericResponse.get("stream");
 InputStreamReader reader = new InputStreamReader(stream, "UTF-8");
 return new JSONTupleStream(reader);
}

代码示例来源:origin: com.hynnet/solr-solrj

public static JSONTupleStream create(SolrClient server, SolrParams requestParams) throws IOException, SolrServerException {
 String p = requestParams.get("qt");
 if(p != null) {
  ModifiableSolrParams modifiableSolrParams = (ModifiableSolrParams) requestParams;
  modifiableSolrParams.remove("qt");
 }
 QueryRequest query = new QueryRequest( requestParams );
 query.setPath(p);
 query.setResponseParser(new InputStreamResponseParser("json"));
 query.setMethod(SolrRequest.METHOD.POST);
 NamedList<Object> genericResponse = server.request(query);
 InputStream stream = (InputStream)genericResponse.get("stream");
 InputStreamReader reader = new InputStreamReader(stream, "UTF-8");
 return new JSONTupleStream(reader);
}

代码示例来源:origin: org.apache.solr/solr-solrj

request.setPath("/admin/collections");
NamedList cluster = (SimpleOrderedMap) client.request(request).get("cluster");
Map<String, Object> collectionsMap;

代码示例来源:origin: org.apache.solr/solr-solrj

public TupleStreamParser constructParser(SolrClient server, SolrParams requestParams) throws IOException, SolrServerException {
  String p = requestParams.get("qt");
  if (p != null) {
   ModifiableSolrParams modifiableSolrParams = (ModifiableSolrParams) requestParams;
   modifiableSolrParams.remove("qt");
   //performance optimization - remove extra whitespace by default when streaming
   modifiableSolrParams.set("indent", modifiableSolrParams.get("indent", "off"));
  }

  String wt = requestParams.get(CommonParams.WT, "json");
  QueryRequest query = new QueryRequest(requestParams);
  query.setPath(p);
  query.setResponseParser(new InputStreamResponseParser(wt));
  query.setMethod(SolrRequest.METHOD.POST);
  NamedList<Object> genericResponse = server.request(query);
  InputStream stream = (InputStream) genericResponse.get("stream");
  this.closeableHttpResponse = (CloseableHttpResponse)genericResponse.get("closeableResponse");
  if (CommonParams.JAVABIN.equals(wt)) {
   return new JavabinTupleStreamParser(stream, true);
  } else {
   InputStreamReader reader = new InputStreamReader(stream, "UTF-8");
   return new JSONTupleStream(reader);
  }
 }
}

代码示例来源:origin: org.apache.solr/solr-test-framework

public static String getQueryResponse(SolrClient client, String wt, SolrParams params) throws Exception {
 if (client == null) {
  return getQueryResponse(wt, params);
 }
 ModifiableSolrParams p = new ModifiableSolrParams(params);
 p.set("wt", wt);
 String path = p.get("qt");
 p.remove("qt");
 p.set("indent","true");
 QueryRequest query = new QueryRequest( p );
 if (path != null) {
  query.setPath(path);
 }
 query.setResponseParser(new NoOpResponseParser(wt));
 NamedList<Object> rsp = client.request(query);
 String raw = (String)rsp.get("response");
 return raw;
}

相关文章