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

Requests.clusterUpdateSettingsRequest介绍

暂无

代码示例

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final ClusterUpdateSettingsRequest clusterUpdateSettingsRequest = Requests.clusterUpdateSettingsRequest();
  clusterUpdateSettingsRequest.timeout(request.paramAsTime("timeout", clusterUpdateSettingsRequest.timeout()));
  clusterUpdateSettingsRequest.masterNodeTimeout(
      request.paramAsTime("master_timeout", clusterUpdateSettingsRequest.masterNodeTimeout()));
  Map<String, Object> source;
  try (XContentParser parser = request.contentParser()) {
    source = parser.map();
  }
  if (source.containsKey(TRANSIENT)) {
    clusterUpdateSettingsRequest.transientSettings((Map) source.get(TRANSIENT));
  }
  if (source.containsKey(PERSISTENT)) {
    clusterUpdateSettingsRequest.persistentSettings((Map) source.get(PERSISTENT));
  }
  return channel -> client.admin().cluster().updateSettings(clusterUpdateSettingsRequest, new RestToXContentListener<>(channel));
}

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final ClusterUpdateSettingsRequest clusterUpdateSettingsRequest = Requests.clusterUpdateSettingsRequest();
  clusterUpdateSettingsRequest.timeout(request.paramAsTime("timeout", clusterUpdateSettingsRequest.timeout()));
  clusterUpdateSettingsRequest.masterNodeTimeout(
      request.paramAsTime("master_timeout", clusterUpdateSettingsRequest.masterNodeTimeout()));
  Map<String, Object> source;
  try (XContentParser parser = request.contentParser()) {
    source = parser.map();
  }
  if (source.containsKey(TRANSIENT)) {
    clusterUpdateSettingsRequest.transientSettings((Map) source.get(TRANSIENT));
  }
  if (source.containsKey(PERSISTENT)) {
    clusterUpdateSettingsRequest.persistentSettings((Map) source.get(PERSISTENT));
  }
  return channel -> client.admin().cluster().updateSettings(clusterUpdateSettingsRequest, new RestToXContentListener<>(channel));
}

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final ClusterUpdateSettingsRequest clusterUpdateSettingsRequest = Requests.clusterUpdateSettingsRequest();
  clusterUpdateSettingsRequest.timeout(request.paramAsTime("timeout", clusterUpdateSettingsRequest.timeout()));
  clusterUpdateSettingsRequest.masterNodeTimeout(
      request.paramAsTime("master_timeout", clusterUpdateSettingsRequest.masterNodeTimeout()));
  Map<String, Object> source;
  try (XContentParser parser = request.contentParser()) {
    source = parser.map();
  }
  if (source.containsKey(TRANSIENT)) {
    clusterUpdateSettingsRequest.transientSettings((Map) source.get(TRANSIENT));
  }
  if (source.containsKey(PERSISTENT)) {
    clusterUpdateSettingsRequest.persistentSettings((Map) source.get(PERSISTENT));
  }
  return channel -> client.admin().cluster().updateSettings(clusterUpdateSettingsRequest, new RestToXContentListener<>(channel));
}

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

@Override
public void handleRequest(final RestRequest request, final RestChannel channel, final Client client) throws Exception {
  final ClusterUpdateSettingsRequest clusterUpdateSettingsRequest = Requests.clusterUpdateSettingsRequest();
  clusterUpdateSettingsRequest.timeout(request.paramAsTime("timeout", clusterUpdateSettingsRequest.timeout()));
  clusterUpdateSettingsRequest.masterNodeTimeout(request.paramAsTime("master_timeout", clusterUpdateSettingsRequest.masterNodeTimeout()));
  Map<String, Object> source;
  try (XContentParser parser = XContentFactory.xContent(request.content()).createParser(request.content())) {
    source = parser.map();
  }
  if (source.containsKey("transient")) {
    clusterUpdateSettingsRequest.transientSettings((Map) source.get("transient"));
  }
  if (source.containsKey("persistent")) {
    clusterUpdateSettingsRequest.persistentSettings((Map) source.get("persistent"));
  }
  client.admin().cluster().updateSettings(clusterUpdateSettingsRequest, new AcknowledgedRestListener<ClusterUpdateSettingsResponse>(channel) {
    @Override
    protected void addCustomFields(XContentBuilder builder, ClusterUpdateSettingsResponse response) throws IOException {
      builder.startObject("persistent");
      response.getPersistentSettings().toXContent(builder, request);
      builder.endObject();
      builder.startObject("transient");
      response.getTransientSettings().toXContent(builder, request);
      builder.endObject();
    }
  });
}

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

@Override
public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
  final ClusterUpdateSettingsRequest clusterUpdateSettingsRequest = Requests.clusterUpdateSettingsRequest();
  clusterUpdateSettingsRequest.timeout(request.paramAsTime("timeout", clusterUpdateSettingsRequest.timeout()));
  clusterUpdateSettingsRequest.masterNodeTimeout(
      request.paramAsTime("master_timeout", clusterUpdateSettingsRequest.masterNodeTimeout()));
  Map<String, Object> source;
  try (XContentParser parser = request.contentParser()) {
    source = parser.map();
  }
  if (source.containsKey("transient")) {
    clusterUpdateSettingsRequest.transientSettings((Map) source.get("transient"));
  }
  if (source.containsKey("persistent")) {
    clusterUpdateSettingsRequest.persistentSettings((Map) source.get("persistent"));
  }
  return channel -> client.admin().cluster().updateSettings(clusterUpdateSettingsRequest,
      new AcknowledgedRestListener<ClusterUpdateSettingsResponse>(channel) {
        @Override
        protected void addCustomFields(XContentBuilder builder, ClusterUpdateSettingsResponse response) throws IOException {
          builder.startObject("persistent");
          response.getPersistentSettings().toXContent(builder, request);
          builder.endObject();
          builder.startObject("transient");
          response.getTransientSettings().toXContent(builder, request);
          builder.endObject();
        }
      });
}