org.elasticsearch.client.node.NodeClient.search()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(10.3k)|赞(0)|评价(0)|浏览(92)

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

NodeClient.search介绍

暂无

代码示例

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  SearchRequest searchRequest = new SearchRequest();
  /*
   * We have to pull out the call to `source().size(size)` because
   * _update_by_query and _delete_by_query uses this same parsing
   * path but sets a different variable when it sees the `size`
   * url parameter.
   *
   * Note that we can't use `searchRequest.source()::size` because
   * `searchRequest.source()` is null right now. We don't have to
   * guard against it being null in the IntConsumer because it can't
   * be null later. If that is confusing to you then you are in good
   * company.
   */
  IntConsumer setSize = size -> searchRequest.source().size(size);
  request.withContentOrSourceParamParserOrNull(parser ->
    parseSearchRequest(searchRequest, request, parser, setSize));
  return channel -> client.search(searchRequest, new RestStatusToXContentListener<>(channel));
}

代码示例来源：origin: org.elasticsearch/elasticsearch

@Override
public RestChannelConsumer doCatRequest(final RestRequest request, final NodeClient client) {
  String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
  SearchRequest countRequest = new SearchRequest(indices);
  SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().size(0);
  countRequest.source(searchSourceBuilder);
  try {
    request.withContentOrSourceParamParserOrNull(parser -> {
      if (parser == null) {
        QueryBuilder queryBuilder = RestActions.urlParamsToQueryBuilder(request);
        if (queryBuilder != null) {
          searchSourceBuilder.query(queryBuilder);
        }
      } else {
        searchSourceBuilder.query(RestActions.getQueryContent(parser));
      }
    });
  } catch (IOException e) {
    throw new ElasticsearchException("Couldn't parse query", e);
  }
  return channel -> client.search(countRequest, new RestResponseListener<SearchResponse>(channel) {
    @Override
    public RestResponse buildResponse(SearchResponse countResponse) throws Exception {
      return RestTable.buildResponse(buildTable(request, countResponse), channel);
    }
  });
}

代码示例来源：origin: org.elasticsearch/elasticsearch

searchSourceBuilder.terminateAfter(terminateAfter);
return channel -> client.search(countRequest, new RestBuilderListener<SearchResponse>(channel) {
  @Override
  public RestResponse buildResponse(SearchResponse response, XContentBuilder builder) throws Exception {

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  SearchRequest searchRequest = new SearchRequest();
  request.withContentOrSourceParamParserOrNull(parser ->
    parseSearchRequest(searchRequest, request, parser));
  return channel -> client.search(searchRequest, new RestStatusToXContentListener<>(channel));
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  SearchRequest searchRequest = new SearchRequest();
  /*
   * We have to pull out the call to `source().size(size)` because
   * _update_by_query and _delete_by_query uses this same parsing
   * path but sets a different variable when it sees the `size`
   * url parameter.
   *
   * Note that we can't use `searchRequest.source()::size` because
   * `searchRequest.source()` is null right now. We don't have to
   * guard against it being null in the IntConsumer because it can't
   * be null later. If that is confusing to you then you are in good
   * company.
   */
  IntConsumer setSize = size -> searchRequest.source().size(size);
  request.withContentOrSourceParamParserOrNull(parser ->
    parseSearchRequest(searchRequest, request, parser, setSize));
  return channel -> client.search(searchRequest, new RestStatusToXContentListener<>(channel));
}

代码示例来源：origin: codelibs/elasticsearch-dataformat

request);
return channel -> client.search(searchRequest, new SearchResponseListener(
    channel, file, limitBytes, dataContent));

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  SearchRequest searchRequest = new SearchRequest();
  /*
   * We have to pull out the call to `source().size(size)` because
   * _update_by_query and _delete_by_query uses this same parsing
   * path but sets a different variable when it sees the `size`
   * url parameter.
   *
   * Note that we can't use `searchRequest.source()::size` because
   * `searchRequest.source()` is null right now. We don't have to
   * guard against it being null in the IntConsumer because it can't
   * be null later. If that is confusing to you then you are in good
   * company.
   */
  IntConsumer setSize = size -> searchRequest.source().size(size);
  request.withContentOrSourceParamParserOrNull(parser ->
    parseSearchRequest(searchRequest, request, parser, setSize));
  return channel -> client.search(searchRequest, new RestStatusToXContentListener<>(channel));
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

@Override
public RestChannelConsumer doCatRequest(final RestRequest request, final NodeClient client) {
  String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
  SearchRequest countRequest = new SearchRequest(indices);
  SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().size(0);
  countRequest.source(searchSourceBuilder);
  try {
    request.withContentOrSourceParamParserOrNull(parser -> {
      if (parser == null) {
        QueryBuilder queryBuilder = RestActions.urlParamsToQueryBuilder(request);
        if (queryBuilder != null) {
          searchSourceBuilder.query(queryBuilder);
        }
      } else {
        searchSourceBuilder.query(RestActions.getQueryContent(parser));
      }
    });
  } catch (IOException e) {
    throw new ElasticsearchException("Couldn't parse query", e);
  }
  return channel -> client.search(countRequest, new RestResponseListener<SearchResponse>(channel) {
    @Override
    public RestResponse buildResponse(SearchResponse countResponse) throws Exception {
      return RestTable.buildResponse(buildTable(request, countResponse), channel);
    }
  });
}

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

@Override
public RestChannelConsumer doCatRequest(final RestRequest request, final NodeClient client) {
  String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
  SearchRequest countRequest = new SearchRequest(indices);
  SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().size(0);
  countRequest.source(searchSourceBuilder);
  try {
    request.withContentOrSourceParamParserOrNull(parser -> {
      if (parser == null) {
        QueryBuilder queryBuilder = RestActions.urlParamsToQueryBuilder(request);
        if (queryBuilder != null) {
          searchSourceBuilder.query(queryBuilder);
        }
      } else {
        searchSourceBuilder.query(RestActions.getQueryContent(parser));
      }
    });
  } catch (IOException e) {
    throw new ElasticsearchException("Couldn't parse query", e);
  }
  return channel -> client.search(countRequest, new RestResponseListener<SearchResponse>(channel) {
    @Override
    public RestResponse buildResponse(SearchResponse countResponse) throws Exception {
      return RestTable.buildResponse(buildTable(request, countResponse), channel);
    }
  });
}

代码示例来源：origin: apache/servicemix-bundles

@Override
public RestChannelConsumer doCatRequest(final RestRequest request, final NodeClient client) {
  String[] indices = Strings.splitStringByCommaToArray(request.param("index"));
  SearchRequest countRequest = new SearchRequest(indices);
  SearchSourceBuilder searchSourceBuilder = new SearchSourceBuilder().size(0);
  countRequest.source(searchSourceBuilder);
  try {
    request.withContentOrSourceParamParserOrNull(parser -> {
      if (parser == null) {
        QueryBuilder queryBuilder = RestActions.urlParamsToQueryBuilder(request);
        if (queryBuilder != null) {
          searchSourceBuilder.query(queryBuilder);
        }
      } else {
        searchSourceBuilder.query(RestActions.getQueryContent(parser));
      }
    });
  } catch (IOException e) {
    throw new ElasticsearchException("Couldn't parse query", e);
  }
  return channel -> client.search(countRequest, new RestResponseListener<SearchResponse>(channel) {
    @Override
    public RestResponse buildResponse(SearchResponse countResponse) throws Exception {
      return RestTable.buildResponse(buildTable(request, countResponse), channel);
    }
  });
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

@Override
  public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
    final SearchRequest searchRequest = new SearchRequest(
        Strings.splitStringByCommaToArray(request.param("index")), new SearchSourceBuilder());
    searchRequest.indicesOptions(IndicesOptions.fromRequest(request, searchRequest.indicesOptions()));
    try (XContentParser parser = request.contentOrSourceParamParser()) {
      searchRequest.source().suggest(SuggestBuilder.fromXContent(parser));
    }
    searchRequest.routing(request.param("routing"));
    searchRequest.preference(request.param("preference"));
    return channel -> client.search(searchRequest, new RestBuilderListener<SearchResponse>(channel) {
      @Override
      public RestResponse buildResponse(SearchResponse response, XContentBuilder builder) throws Exception {
        RestStatus restStatus = RestStatus.status(response.getSuccessfulShards(),
          response.getTotalShards(), response.getShardFailures());
        builder.startObject();
        buildBroadcastShardsHeader(builder, request, response.getTotalShards(),
          response.getSuccessfulShards(), response.getFailedShards(), response.getShardFailures());
        Suggest suggest = response.getSuggest();
        if (suggest != null) {
          suggest.toInnerXContent(builder, request);
        }
        builder.endObject();
        return new BytesRestResponse(restStatus, builder);
      }
    });
  }
}

代码示例来源：origin: com.strapdata.elasticsearch/elasticsearch

searchSourceBuilder.terminateAfter(terminateAfter);
return channel -> client.search(countRequest, new RestBuilderListener<SearchResponse>(channel) {
  @Override
  public RestResponse buildResponse(SearchResponse response, XContentBuilder builder) throws Exception {

代码示例来源：origin: apache/servicemix-bundles

searchSourceBuilder.terminateAfter(terminateAfter);
return channel -> client.search(countRequest, new RestBuilderListener<SearchResponse>(channel) {
  @Override
  public RestResponse buildResponse(SearchResponse response, XContentBuilder builder) throws Exception {

代码示例来源：origin: org.apache.servicemix.bundles/org.apache.servicemix.bundles.elasticsearch

searchSourceBuilder.terminateAfter(terminateAfter);
return channel -> client.search(countRequest, new RestBuilderListener<SearchResponse>(channel) {
  @Override
  public RestResponse buildResponse(SearchResponse response, XContentBuilder builder) throws Exception {

内容来源于网络，如有侵权，请联系作者删除！

NodeClient

相关文章

    查看更多
    微信公众号

    热门标签

    更多
    JavaquerypythonNode开发语言requestUtil数据库Table后端算法LoggerMessageElementParser

    最新文章

    更多
    • 蜀ICP备13028337号-1 大数据知识库 https://www.saoniuhuo.com © All rights reserved
    • 本站内容来源互联网,如果侵犯您的权益请联系我们删除, 联系方式：448109455@qq.com