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

Requests.clusterRerouteRequest介绍

暂无

代码示例

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

public static ClusterRerouteRequest createRequest(RestRequest request) throws IOException {
    ClusterRerouteRequest clusterRerouteRequest = Requests.clusterRerouteRequest();
    clusterRerouteRequest.dryRun(request.paramAsBoolean("dry_run", clusterRerouteRequest.dryRun()));
    clusterRerouteRequest.explain(request.paramAsBoolean("explain", clusterRerouteRequest.explain()));
    clusterRerouteRequest.timeout(request.paramAsTime("timeout", clusterRerouteRequest.timeout()));
    clusterRerouteRequest.setRetryFailed(request.paramAsBoolean("retry_failed", clusterRerouteRequest.isRetryFailed()));
    clusterRerouteRequest.masterNodeTimeout(request.paramAsTime("master_timeout", clusterRerouteRequest.masterNodeTimeout()));
    request.applyContentParser(parser -> PARSER.parse(parser, clusterRerouteRequest, null));
    return clusterRerouteRequest;
  }
}

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

public static ClusterRerouteRequest createRequest(RestRequest request) throws IOException {
    ClusterRerouteRequest clusterRerouteRequest = Requests.clusterRerouteRequest();
    clusterRerouteRequest.dryRun(request.paramAsBoolean("dry_run", clusterRerouteRequest.dryRun()));
    clusterRerouteRequest.explain(request.paramAsBoolean("explain", clusterRerouteRequest.explain()));
    clusterRerouteRequest.timeout(request.paramAsTime("timeout", clusterRerouteRequest.timeout()));
    clusterRerouteRequest.setRetryFailed(request.paramAsBoolean("retry_failed", clusterRerouteRequest.isRetryFailed()));
    clusterRerouteRequest.masterNodeTimeout(request.paramAsTime("master_timeout", clusterRerouteRequest.masterNodeTimeout()));
    request.applyContentParser(parser -> PARSER.parse(parser, clusterRerouteRequest, null));
    return clusterRerouteRequest;
  }
}

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

public static ClusterRerouteRequest createRequest(RestRequest request) throws IOException {
    ClusterRerouteRequest clusterRerouteRequest = Requests.clusterRerouteRequest();
    clusterRerouteRequest.dryRun(request.paramAsBoolean("dry_run", clusterRerouteRequest.dryRun()));
    clusterRerouteRequest.explain(request.paramAsBoolean("explain", clusterRerouteRequest.explain()));
    clusterRerouteRequest.timeout(request.paramAsTime("timeout", clusterRerouteRequest.timeout()));
    clusterRerouteRequest.setRetryFailed(request.paramAsBoolean("retry_failed", clusterRerouteRequest.isRetryFailed()));
    clusterRerouteRequest.masterNodeTimeout(request.paramAsTime("master_timeout", clusterRerouteRequest.masterNodeTimeout()));
    request.applyContentParser(parser -> PARSER.parse(parser, clusterRerouteRequest, null));
    return clusterRerouteRequest;
  }
}

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

public static ClusterRerouteRequest createRequest(RestRequest request) throws IOException {
    ClusterRerouteRequest clusterRerouteRequest = Requests.clusterRerouteRequest();
    clusterRerouteRequest.dryRun(request.paramAsBoolean("dry_run", clusterRerouteRequest.dryRun()));
    clusterRerouteRequest.explain(request.paramAsBoolean("explain", clusterRerouteRequest.explain()));
    clusterRerouteRequest.timeout(request.paramAsTime("timeout", clusterRerouteRequest.timeout()));
    clusterRerouteRequest.setRetryFailed(request.paramAsBoolean("retry_failed", clusterRerouteRequest.isRetryFailed()));
    clusterRerouteRequest.masterNodeTimeout(request.paramAsTime("master_timeout", clusterRerouteRequest.masterNodeTimeout()));
    request.applyContentParser(parser -> PARSER.parse(parser, clusterRerouteRequest, null));
    return clusterRerouteRequest;
  }
}

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

@Override
  public void handleRequest(final RestRequest request, final RestChannel channel, final Client client) throws Exception {
    final ClusterRerouteRequest clusterRerouteRequest = Requests.clusterRerouteRequest();
    clusterRerouteRequest.dryRun(request.paramAsBoolean("dry_run", clusterRerouteRequest.dryRun()));
    clusterRerouteRequest.explain(request.paramAsBoolean("explain", clusterRerouteRequest.explain()));
    clusterRerouteRequest.timeout(request.paramAsTime("timeout", clusterRerouteRequest.timeout()));
    clusterRerouteRequest.masterNodeTimeout(request.paramAsTime("master_timeout", clusterRerouteRequest.masterNodeTimeout()));
    if (request.hasContent()) {
      clusterRerouteRequest.source(request.content());
    }

    client.admin().cluster().reroute(clusterRerouteRequest, new AcknowledgedRestListener<ClusterRerouteResponse>(channel) {
      @Override
      protected void addCustomFields(XContentBuilder builder, ClusterRerouteResponse response) throws IOException {
        builder.startObject("state");
        // by default, return everything but metadata
        if (request.param("metric") == null) {
          request.params().put("metric", DEFAULT_METRICS);
        }
        settingsFilter.addFilterSettingParams(request);
        response.getState().toXContent(builder, request);
        builder.endObject();
        if (clusterRerouteRequest.explain()) {
          assert response.getExplanations() != null;
          response.getExplanations().toXContent(builder, ToXContent.EMPTY_PARAMS);
        }
      }
    });
  }
}