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

Client.clearScroll介绍

[英]Clears the search contexts associated with specified scroll ids.
[中]

代码示例

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

@Override
public void clearScroll(String scrollId, Runnable onCompletion) {
  ClearScrollRequest clearScrollRequest = new ClearScrollRequest();
  clearScrollRequest.addScrollId(scrollId);
  /*
   * Unwrap the client so we don't set our task as the parent. If we *did* set our ID then the clear scroll would be cancelled as
   * if this task is cancelled. But we want to clear the scroll regardless of whether or not the main request was cancelled.
   */
  client.unwrap().clearScroll(clearScrollRequest, new ActionListener<ClearScrollResponse>() {
    @Override
    public void onResponse(ClearScrollResponse response) {
      logger.debug("Freed [{}] contexts", response.getNumFreed());
      onCompletion.run();
    }
    @Override
    public void onFailure(Exception e) {
      logger.warn(() -> new ParameterizedMessage("Failed to clear scroll [{}]", scrollId), e);
      onCompletion.run();
    }
  });
}

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

@Override
public ClearScrollResponse clearScroll(ClearScrollRequest request) {
  return client.clearScroll(request).actionGet();
}

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

@Override
public void clearScroll(String scrollId, Runnable onCompletion) {
  ClearScrollRequest clearScrollRequest = new ClearScrollRequest();
  clearScrollRequest.addScrollId(scrollId);
  /*
   * Unwrap the client so we don't set our task as the parent. If we *did* set our ID then the clear scroll would be cancelled as
   * if this task is cancelled. But we want to clear the scroll regardless of whether or not the main request was cancelled.
   */
  client.unwrap().clearScroll(clearScrollRequest, new ActionListener<ClearScrollResponse>() {
    @Override
    public void onResponse(ClearScrollResponse response) {
      logger.debug("Freed [{}] contexts", response.getNumFreed());
      onCompletion.run();
    }
    @Override
    public void onFailure(Exception e) {
      logger.warn(() -> new ParameterizedMessage("Failed to clear scroll [{}]", scrollId), e);
      onCompletion.run();
    }
  });
}

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

@Override
public void clearScroll(String scrollId, Runnable onCompletion) {
  ClearScrollRequest clearScrollRequest = new ClearScrollRequest();
  clearScrollRequest.addScrollId(scrollId);
  /*
   * Unwrap the client so we don't set our task as the parent. If we *did* set our ID then the clear scroll would be cancelled as
   * if this task is cancelled. But we want to clear the scroll regardless of whether or not the main request was cancelled.
   */
  client.unwrap().clearScroll(clearScrollRequest, new ActionListener<ClearScrollResponse>() {
    @Override
    public void onResponse(ClearScrollResponse response) {
      logger.debug("Freed [{}] contexts", response.getNumFreed());
      onCompletion.run();
    }
    @Override
    public void onFailure(Exception e) {
      logger.warn((Supplier<?>) () -> new ParameterizedMessage("Failed to clear scroll [{}]", scrollId), e);
      onCompletion.run();
    }
  });
}

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

@Override
public void clearScroll(String scrollId, Runnable onCompletion) {
  ClearScrollRequest clearScrollRequest = new ClearScrollRequest();
  clearScrollRequest.addScrollId(scrollId);
  /*
   * Unwrap the client so we don't set our task as the parent. If we *did* set our ID then the clear scroll would be cancelled as
   * if this task is cancelled. But we want to clear the scroll regardless of whether or not the main request was cancelled.
   */
  client.unwrap().clearScroll(clearScrollRequest, new ActionListener<ClearScrollResponse>() {
    @Override
    public void onResponse(ClearScrollResponse response) {
      logger.debug("Freed [{}] contexts", response.getNumFreed());
      onCompletion.run();
    }
    @Override
    public void onFailure(Exception e) {
      logger.warn(() -> new ParameterizedMessage("Failed to clear scroll [{}]", scrollId), e);
      onCompletion.run();
    }
  });
}

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

client.clearScroll(clearScrollRequest, new ActionListener<ClearScrollResponse>() {
  @Override
  public void onResponse(ClearScrollResponse response) {

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

client.clearScroll(clearScrollRequest, new ActionListener<ClearScrollResponse>() {
  @Override
  public void onResponse(ClearScrollResponse response) {

代码示例来源：origin: org.elasticsearch.plugin/delete-by-query

ClearScrollRequest clearScrollRequest = new ClearScrollRequest(request);
clearScrollRequest.addScrollId(scrollId);
client.clearScroll(clearScrollRequest, new ActionListener<ClearScrollResponse>() {
  @Override
  public void onResponse(ClearScrollResponse clearScrollResponse) {

代码示例来源：origin: harbby/presto-connectors

@Override
public void handleRequest(final RestRequest request, final RestChannel channel, final Client client) {
  String scrollIds = request.param("scroll_id");
  ClearScrollRequest clearRequest = new ClearScrollRequest();
  clearRequest.setScrollIds(Arrays.asList(splitScrollIds(scrollIds)));
  if (RestActions.hasBodyContent(request)) {
    XContentType type = RestActions.guessBodyContentType(request);
    if (type == null) {
      scrollIds = RestActions.getRestContent(request).toUtf8();
      clearRequest.setScrollIds(Arrays.asList(splitScrollIds(scrollIds)));
    } else {
      // NOTE: if rest request with xcontent body has request parameters, these parameters does not override xcontent value
      clearRequest.setScrollIds(null);
      buildFromContent(RestActions.getRestContent(request), clearRequest);
    }
  }
  client.clearScroll(clearRequest, new RestStatusToXContentListener<ClearScrollResponse>(channel));
}