org.elasticsearch.client.RestHighLevelClient.performRequest()方法的使用及代码示例

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

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

RestHighLevelClient.performRequest介绍

暂无

代码示例

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Checks for the existence of a document with a "_source" field. Returns true if it exists, false otherwise.
 * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-get.html#_source">Source exists API
 * on elastic.co</a>
 * @param getRequest the request
 * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
 * @return <code>true</code> if the document and _source field exists, <code>false</code> otherwise
 */
public boolean existsSource(GetRequest getRequest, RequestOptions options) throws IOException {
  return performRequest(getRequest, RequestConverters::sourceExists, options, RestHighLevelClient::convertExistsResponse, emptySet());
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Checks for the existence of a document. Returns true if it exists, false otherwise.
 * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-get.html">Get API on elastic.co</a>
 * @param getRequest the request
 * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
 * @return <code>true</code> if the document exists, <code>false</code> otherwise
 */
public final boolean exists(GetRequest getRequest, RequestOptions options) throws IOException {
  return performRequest(getRequest, RequestConverters::exists, options, RestHighLevelClient::convertExistsResponse, emptySet());
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Uses the Index Templates API to determine if index templates exist
 *
 * @param indexTemplatesRequest the request
 * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
 * @return true if any index templates in the request exist, false otherwise
 * @throws IOException in case there is a problem sending the request or parsing back the response
 */
public boolean existsTemplate(IndexTemplatesExistRequest indexTemplatesRequest, RequestOptions options) throws IOException {
  return restHighLevelClient.performRequest(indexTemplatesRequest, IndicesRequestConverters::templatesExist, options,
    RestHighLevelClient::convertExistsResponse, emptySet());
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Checks if one or more aliases exist using the Aliases Exist API.
 * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-aliases.html">
 * Indices Aliases API on elastic.co</a>
 * @param getAliasesRequest the request
 * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
 * @return the response
 * @throws IOException in case there is a problem sending the request
 */
public boolean existsAlias(GetAliasesRequest getAliasesRequest, RequestOptions options) throws IOException {
  return restHighLevelClient.performRequest(getAliasesRequest, IndicesRequestConverters::existsAlias, options,
      RestHighLevelClient::convertExistsResponse, emptySet());
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Checks if one or more aliases exist using the Aliases Exist API.
 * <p>
 * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-aliases.html">
 * Indices Aliases API on elastic.co</a>
 * @deprecated Prefer {@link #existsAlias(GetAliasesRequest, RequestOptions)}
 */
@Deprecated
public boolean existsAlias(GetAliasesRequest getAliasesRequest, Header... headers) throws IOException {
  return restHighLevelClient.performRequest(getAliasesRequest, IndicesRequestConverters::existsAlias,
      RestHighLevelClient::convertExistsResponse, emptySet(), headers);
}

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

/**
 * Checks if one or more aliases exist using the Aliases Exist API.
 * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-aliases.html">
 * Indices Aliases API on elastic.co</a>
 * @param getAliasesRequest the request
 * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
 * @return the response
 * @throws IOException in case there is a problem sending the request
 */
public boolean existsAlias(GetAliasesRequest getAliasesRequest, RequestOptions options) throws IOException {
  return restHighLevelClient.performRequest(getAliasesRequest, IndicesRequestConverters::existsAlias, options,
      RestHighLevelClient::convertExistsResponse, emptySet());
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Checks if the index (indices) exists or not.
 * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-exists.html">
 * Indices Exists API on elastic.co</a>
 * @param request the request
 * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
 * @return the response
 * @throws IOException in case there is a problem sending the request
 */
public boolean exists(GetIndexRequest request, RequestOptions options) throws IOException {
  return restHighLevelClient.performRequest(
    request,
    IndicesRequestConverters::indicesExist,
    options,
    RestHighLevelClient::convertExistsResponse,
    Collections.emptySet()
  );
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Checks for the existence of a document. Returns true if it exists, false otherwise.
 *
 * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/docs-get.html">Get API on elastic.co</a>
 * @deprecated Prefer {@link #exists(GetRequest, RequestOptions)}
 */
@Deprecated
public final boolean exists(GetRequest getRequest, Header... headers) throws IOException {
  return performRequest(getRequest, RequestConverters::exists, RestHighLevelClient::convertExistsResponse, emptySet(), headers);
}

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

/**
 * Checks if one or more aliases exist using the Aliases Exist API.
 * <p>
 * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-aliases.html">
 * Indices Aliases API on elastic.co</a>
 * @deprecated Prefer {@link #existsAlias(GetAliasesRequest, RequestOptions)}
 */
@Deprecated
public boolean existsAlias(GetAliasesRequest getAliasesRequest, Header... headers) throws IOException {
  return restHighLevelClient.performRequest(getAliasesRequest, IndicesRequestConverters::existsAlias,
      RestHighLevelClient::convertExistsResponse, emptySet(), headers);
}

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

/**
 * Checks if the index (indices) exists or not.
 * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-exists.html">
 * Indices Exists API on elastic.co</a>
 * @param request the request
 * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
 * @return the response
 * @throws IOException in case there is a problem sending the request
 */
public boolean exists(GetIndexRequest request, RequestOptions options) throws IOException {
  return restHighLevelClient.performRequest(
    request,
    IndicesRequestConverters::indicesExist,
    options,
    RestHighLevelClient::convertExistsResponse,
    Collections.emptySet()
  );
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Checks if the index (indices) exists or not.
 * <p>
 * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/indices-exists.html">
 * Indices Exists API on elastic.co</a>
 * @deprecated Prefer {@link #exists(GetIndexRequest, RequestOptions)}
 */
@Deprecated
public boolean exists(GetIndexRequest request, Header... headers) throws IOException {
  return restHighLevelClient.performRequest(
      request,
      IndicesRequestConverters::indicesExist,
      RestHighLevelClient::convertExistsResponse,
      Collections.emptySet(),
      headers
  );
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

@Deprecated
protected final <Req extends ActionRequest, Resp> Resp performRequest(Req request,
                           CheckedFunction<Req, Request, IOException> requestConverter,
                           CheckedFunction<Response, Resp, IOException> responseConverter,
                           Set<Integer> ignores, Header... headers) throws IOException {
  return performRequest(request, requestConverter, optionsForHeaders(headers), responseConverter, ignores);
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Pings the remote Elasticsearch cluster and returns true if the ping succeeded, false otherwise
 * @deprecated Prefer {@link #ping(RequestOptions)}
 */
@Deprecated
public final boolean ping(Header... headers) throws IOException {
  return performRequest(new MainRequest(), (request) -> RequestConverters.ping(), RestHighLevelClient::convertExistsResponse,
      emptySet(), headers);
}

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

/**
 * Returns the current license for the cluster.
 * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
 * @return the response
 * @throws IOException in case there is a problem sending the request or parsing back the response
 */
public GetLicenseResponse getLicense(GetLicenseRequest request, RequestOptions options) throws IOException {
  return restHighLevelClient.performRequest(request, LicenseRequestConverters::getLicense, options,
    response -> new GetLicenseResponse(convertResponseToJson(response)), emptySet());
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Returns the current license for the cluster.
 * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
 * @return the response
 * @throws IOException in case there is a problem sending the request or parsing back the response
 */
public GetLicenseResponse getLicense(GetLicenseRequest request, RequestOptions options) throws IOException {
  return restHighLevelClient.performRequest(request, LicenseRequestConverters::getLicense, options,
    response -> new GetLicenseResponse(convertResponseToJson(response)), emptySet());
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Pings the remote Elasticsearch cluster and returns true if the ping succeeded, false otherwise
 * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
 * @return <code>true</code> if the ping succeeded, false otherwise
 */
public final boolean ping(RequestOptions options) throws IOException {
  return performRequest(new MainRequest(), (request) -> RequestConverters.ping(), options, RestHighLevelClient::convertExistsResponse,
      emptySet());
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

@Deprecated
protected final <Req extends ActionRequest, Resp> Resp performRequestAndParseEntity(Req request,
                                    CheckedFunction<Req, Request, IOException> requestConverter,
                                    CheckedFunction<XContentParser, Resp, IOException> entityParser,
                                    Set<Integer> ignores, Header... headers) throws IOException {
  return performRequest(request, requestConverter, (response) -> parseEntity(response.getEntity(), entityParser), ignores, headers);
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * @deprecated If creating a new HLRC ReST API call, consider creating new actions instead of reusing server actions. The Validation
 * layer has been added to the ReST client, and requests should extend {@link Validatable} instead of {@link ActionRequest}.
 */
@Deprecated
protected final <Req extends ActionRequest, Resp> Resp performRequestAndParseEntity(Req request,
                                    CheckedFunction<Req, Request, IOException> requestConverter,
                                    RequestOptions options,
                                    CheckedFunction<XContentParser, Resp, IOException> entityParser,
                                    Set<Integer> ignores) throws IOException {
  return performRequest(request, requestConverter, options,
      response -> parseEntity(response.getEntity(), entityParser), ignores);
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Defines a helper method for performing a request and then parsing the returned entity using the provided entityParser.
 */
protected final <Req extends Validatable, Resp> Resp performRequestAndParseEntity(Req request,
                                   CheckedFunction<Req, Request, IOException> requestConverter,
                                   RequestOptions options,
                                   CheckedFunction<XContentParser, Resp, IOException> entityParser,
                                   Set<Integer> ignores) throws IOException {
  return performRequest(request, requestConverter, options,
    response -> parseEntity(response.getEntity(), entityParser), ignores);
}

代码示例来源:origin: org.elasticsearch.client/elasticsearch-rest-high-level-client

/**
 * Executes a request using the Explain API.
 * See <a href="https://www.elastic.co/guide/en/elasticsearch/reference/current/search-explain.html">Explain API on elastic.co</a>
 * @param explainRequest the request
 * @param options the request options (e.g. headers), use {@link RequestOptions#DEFAULT} if nothing needs to be customized
 * @return the response
 */
public final ExplainResponse explain(ExplainRequest explainRequest, RequestOptions options) throws IOException {
  return performRequest(explainRequest, RequestConverters::explain, options,
    response -> {
      CheckedFunction<XContentParser, ExplainResponse, IOException> entityParser =
        parser -> ExplainResponse.fromXContent(parser, convertExistsResponse(response));
      return parseEntity(response.getEntity(), entityParser);
    },
    singleton(404));
}

相关文章