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

RestHighLevelClient.ingest介绍

[英]Provides a IngestClient which can be used to access the Ingest API. See Ingest API on elastic.co
[中]提供可用于访问摄取API的摄取客户端。见Ingest API on elastic.co

代码示例

代码示例来源：origin: dadoonet/fscrawler

/**
 * Check if a pipeline exists
 * @param pipelineName pipeline name
 * @return true if the pipeline exists, false otherwise
 * @throws IOException In case of error
 */
public boolean isExistingPipeline(String pipelineName) throws IOException {
  logger.debug("is existing pipeline [{}]", pipelineName);
  try {
    return client.ingest().getPipeline(new GetPipelineRequest(pipelineName), RequestOptions.DEFAULT).isFound();
  } catch (ElasticsearchStatusException e) {
    if (e.status().getStatus() == 404) {
      return false;
    }
    throw new IOException(e);
  }
}

代码示例来源：origin: dadoonet/fscrawler

/**
 * Check if a pipeline exists
 * @param pipelineName pipeline name
 * @return true if the pipeline exists, false otherwise
 * @throws IOException In case of error
 */
public boolean isExistingPipeline(String pipelineName) throws IOException {
  logger.debug("is existing pipeline [{}]", pipelineName);
  try {
    return client.ingest().getPipeline(new GetPipelineRequest(pipelineName), RequestOptions.DEFAULT).isFound();
  } catch (ElasticsearchStatusException e) {
    if (e.status().getStatus() == 404) {
      return false;
    }
    throw new IOException(e);
  }
}

代码示例来源：origin: io.reactiverse/elasticsearch-client

@Override()
public IngestClient ingest() {
  return new IngestClientImpl(vertx, delegate.ingest());
}