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

IndicesAdminClient.getSettings介绍

[英]Executed a per index settings get request.
[中]已执行按索引设置获取请求。

代码示例

代码示例来源：origin: thinkaurelius/titan

@Test
public void testIndexCreationOptions() throws InterruptedException, BackendException {
  final int shards = 77;
  ElasticsearchRunner esr = new ElasticsearchRunner(".", "indexCreationOptions.yml");
  esr.start();
  CommonsConfiguration cc = new CommonsConfiguration(new BaseConfiguration());
  cc.set("index." + INDEX_NAME + ".elasticsearch.create.ext.number_of_shards", String.valueOf(shards));
  cc.set("index." + INDEX_NAME + ".elasticsearch.ext.cluster.name", "indexCreationOptions");
  ModifiableConfiguration config =
      new ModifiableConfiguration(GraphDatabaseConfiguration.ROOT_NS,
          cc, BasicConfiguration.Restriction.NONE);
  config.set(INTERFACE, ElasticSearchSetup.NODE.toString(), INDEX_NAME);
  Configuration indexConfig = config.restrictTo(INDEX_NAME);
  IndexProvider idx = new ElasticSearchIndex(indexConfig);
  simpleWriteAndQuery(idx);
  ImmutableSettings.Builder settingsBuilder = ImmutableSettings.settingsBuilder();
  settingsBuilder.put("discovery.zen.ping.multicast.enabled", "false");
  settingsBuilder.put("discovery.zen.ping.unicast.hosts", "localhost,127.0.0.1:9300");
  settingsBuilder.put("cluster.name", "indexCreationOptions");
  NodeBuilder nodeBuilder = NodeBuilder.nodeBuilder().settings(settingsBuilder.build());
  nodeBuilder.client(true).data(false).local(false);
  Node n = nodeBuilder.build().start();
  GetSettingsResponse response = n.client().admin().indices().getSettings(new GetSettingsRequest().indices("titan")).actionGet();
  assertEquals(String.valueOf(shards), response.getSetting("titan", "index.number_of_shards"));
  idx.close();
  n.stop();
  esr.stop();
}

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

@Override
  public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
    final String[] names = request.paramAsStringArrayOrEmptyIfAll("name");
    final boolean renderDefaults = request.paramAsBoolean("include_defaults", false);
    // This is required so the "flat_settings" parameter counts as consumed
    request.paramAsBoolean("flat_settings", false);
    GetSettingsRequest getSettingsRequest = new GetSettingsRequest()
        .indices(Strings.splitStringByCommaToArray(request.param("index")))
        .indicesOptions(IndicesOptions.fromRequest(request, IndicesOptions.strictExpandOpen()))
        .humanReadable(request.hasParam("human"))
        .includeDefaults(renderDefaults)
        .names(names);
    getSettingsRequest.local(request.paramAsBoolean("local", getSettingsRequest.local()));
    getSettingsRequest.masterNodeTimeout(request.paramAsTime("master_timeout", getSettingsRequest.masterNodeTimeout()));
    return channel -> client.admin().indices().getSettings(getSettingsRequest, new RestToXContentListener<>(channel));
  }
}

代码示例来源：origin: dqeasycloud/easy-cloud

@Override
public Map<String, Map<String, String>> getAllSetting() {
  Map<String, Map<String, String>> map = new HashMap<>();
  ImmutableOpenMap<String, Settings> indexToSettings = getIndicesAdminClient().getSettings(new GetSettingsRequest()).actionGet().getIndexToSettings();
  Iterator<ObjectObjectCursor<String, Settings>> iterator = indexToSettings.iterator();
  while (iterator.hasNext()) {
    ObjectObjectCursor<String, Settings> objectObjectCursor = iterator.next();
    map.put(objectObjectCursor.key, getSettingMap(objectObjectCursor.value));
  }
  return map;
}

代码示例来源：origin: dqeasycloud/easy-cloud

@Override
public Map<String, String> getSetting(String indexName) {
  Assert.notNull(indexName, "No index defined for getSetting()");
  Settings settings = client.admin().indices().getSettings(new GetSettingsRequest()).actionGet()
      .getIndexToSettings().get(indexName);
  return getSettingMap(settings);
}

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

@Override
public void handleRequest(final RestRequest request, final RestChannel channel, final Client client) {
  final String[] names = request.paramAsStringArrayOrEmptyIfAll("name");
  GetSettingsRequest getSettingsRequest = new GetSettingsRequest()
      .indices(Strings.splitStringByCommaToArray(request.param("index")))
      .indicesOptions(IndicesOptions.fromRequest(request, IndicesOptions.strictExpandOpen()))
      .humanReadable(request.hasParam("human"))
      .names(names);
  getSettingsRequest.local(request.paramAsBoolean("local", getSettingsRequest.local()));
  client.admin().indices().getSettings(getSettingsRequest, new RestBuilderListener<GetSettingsResponse>(channel) {
    @Override
    public RestResponse buildResponse(GetSettingsResponse getSettingsResponse, XContentBuilder builder) throws Exception {
      builder.startObject();
      for (ObjectObjectCursor<String, Settings> cursor : getSettingsResponse.getIndexToSettings()) {
        // no settings, jump over it to shorten the response data
        if (cursor.value.getAsMap().isEmpty()) {
          continue;
        }
        builder.startObject(cursor.key, XContentBuilder.FieldCaseConversion.NONE);
        builder.startObject(Fields.SETTINGS);
        cursor.value.toXContent(builder, request);
        builder.endObject();
        builder.endObject();
      }
      builder.endObject();
      return new BytesRestResponse(OK, builder);
    }
  });
}

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

getSettingsRequest.local(request.paramAsBoolean("local", getSettingsRequest.local()));
return channel -> client.admin().indices().getSettings(getSettingsRequest, new RestBuilderListener<GetSettingsResponse>(channel) {

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

@Override
  public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
    final String[] names = request.paramAsStringArrayOrEmptyIfAll("name");
    final boolean renderDefaults = request.paramAsBoolean("include_defaults", false);
    // This is required so the "flat_settings" parameter counts as consumed
    request.paramAsBoolean("flat_settings", false);
    GetSettingsRequest getSettingsRequest = new GetSettingsRequest()
        .indices(Strings.splitStringByCommaToArray(request.param("index")))
        .indicesOptions(IndicesOptions.fromRequest(request, IndicesOptions.strictExpandOpen()))
        .humanReadable(request.hasParam("human"))
        .includeDefaults(renderDefaults)
        .names(names);
    getSettingsRequest.local(request.paramAsBoolean("local", getSettingsRequest.local()));
    getSettingsRequest.masterNodeTimeout(request.paramAsTime("master_timeout", getSettingsRequest.masterNodeTimeout()));
    return channel -> client.admin().indices().getSettings(getSettingsRequest, new RestToXContentListener<>(channel));
  }
}

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

@Override
  public RestChannelConsumer prepareRequest(final RestRequest request, final NodeClient client) throws IOException {
    final String[] names = request.paramAsStringArrayOrEmptyIfAll("name");
    final boolean renderDefaults = request.paramAsBoolean("include_defaults", false);
    // This is required so the "flat_settings" parameter counts as consumed
    request.paramAsBoolean("flat_settings", false);
    GetSettingsRequest getSettingsRequest = new GetSettingsRequest()
        .indices(Strings.splitStringByCommaToArray(request.param("index")))
        .indicesOptions(IndicesOptions.fromRequest(request, IndicesOptions.strictExpandOpen()))
        .humanReadable(request.hasParam("human"))
        .includeDefaults(renderDefaults)
        .names(names);
    getSettingsRequest.local(request.paramAsBoolean("local", getSettingsRequest.local()));
    getSettingsRequest.masterNodeTimeout(request.paramAsTime("master_timeout", getSettingsRequest.masterNodeTimeout()));
    return channel -> client.admin().indices().getSettings(getSettingsRequest, new RestToXContentListener<>(channel));
  }
}