import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
/**
 * 索引的相关操作
 *
 * @param indicesAdminClient
 * @param indexName
 * @throws IOException
 */
private static void indexConfig(IndicesAdminClient indicesAdminClient, String indexName) throws IOException {
    //settings 设置
    String settings = getIndexSetting();
    // PUT /my_temp_index/_settings updatesettings
    showIndexSettings(indicesAdminClient,indexName);
    UpdateSettingsResponse updateSettingsResponse = indicesAdminClient.prepareUpdateSettings(indexName).setSettings(settings).execute().actionGet();
    log.info("更新 index setting:{}", updateSettingsResponse);


    //更新索引settings之前要关闭索引
    indicesAdminClient.close(new CloseIndexRequest().indices(indexName)).actionGet();
    //配置拼音自定义分析器
    indicesAdminClient.prepareUpdateSettings(indexName).setSettings(getIndexPinYinSetting()).execute().actionGet();
    //自定义分析器
    indicesAdminClient.prepareUpdateSettings(indexName).setSettings(getIndexDemoSetting()).execute().actionGet();
    //打开索引
    indicesAdminClient.open(new OpenIndexRequest().indices(indexName)).actionGet();

    //索引别名映射
    createAliasIndex(indicesAdminClient);

    showIndexSettings(indicesAdminClient,indexName);
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
private void setIndexReadOnly(String index, Object value) {
    HashMap<String, Object> newSettings = new HashMap<>();
    newSettings.put(IndexMetaData.SETTING_READ_ONLY, value);

    UpdateSettingsRequestBuilder settingsRequest = client().admin().indices().prepareUpdateSettings(index);
    settingsRequest.setSettings(newSettings);
    UpdateSettingsResponse settingsResponse = settingsRequest.execute().actionGet();
    assertThat(settingsResponse, notNullValue());
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
/**
 * can be used to alter the number of replicas.
 *
 * @param tableName name of the blob table
 * @param indexSettings updated index settings
 */
public ListenableFuture<Void> alterBlobTable(String tableName, Settings indexSettings) {
    final SettableFuture<Void> result = SettableFuture.create();
    ActionListener<UpdateSettingsResponse> listener = ActionListeners.wrap(result, Functions.<Void>constant(null));
    transportUpdateSettingsActionProvider.get().execute(
        new UpdateSettingsRequest(indexSettings, fullIndexName(tableName)), listener);
    return result;
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
private ListenableFuture<Long> updateSettings(TableParameter concreteTableParameter, String... indices) {
    if (concreteTableParameter.settings().getAsMap().isEmpty() || indices.length == 0) {
        return Futures.immediateFuture(null);
    }
    UpdateSettingsRequest request = new UpdateSettingsRequest(concreteTableParameter.settings(), indices);
    request.indicesOptions(IndicesOptions.lenientExpandOpen());

    SettableFuture<Long> result = SettableFuture.create();
    transportActionProvider.transportUpdateSettingsAction().execute(request,
            new SettableFutureToNullActionListener<UpdateSettingsResponse>(result));
    return result;
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
/**
 * updateIndexSetting
 * 
 * @param index
 * @param set
 * @return
 */
public boolean updateIndexSetting(String index, Map<String, Object> set) {

    try {
        UpdateSettingsResponse usr = client.admin().indices().prepareUpdateSettings(index).setSettings(set).get();
        return usr.isAcknowledged();
    }
    catch (Exception e) {
        return false;
    }
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
@Test
public void testPutSettings() {
    createIndex("the_index");
    String settings = "" +
            "{\n" +
            "  \"number_of_replicas\": 1\n" +
            "}" +
            "";
    UpdateSettingsResponse response = operations.putSettings(settings, "the_index").actionGet();
    Assertions.assertThat(response.isAcknowledged()).isTrue();
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
@Override
public ActionFuture<UpdateSettingsResponse> updateSettings(final UpdateSettingsRequest request) {
    return execute(UpdateSettingsAction.INSTANCE, request);
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
public void testUpdateSettingsNoAcknowledgement() {
    createIndex("test");
    UpdateSettingsResponse updateSettingsResponse = client().admin().indices().prepareUpdateSettings("test").setTimeout("0s")
            .setSettings(Settings.builder().put("refresh_interval", 9999, TimeUnit.MILLISECONDS)).get();
    assertThat(updateSettingsResponse.isAcknowledged(), equalTo(false));
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
public ActionFuture<UpdateSettingsResponse> disableRefresh(String... indices) {
    logger.trace("Disabling refresh on {}", Arrays.asList(indices));
    return updateSettings(Collections.singletonMap("refresh_interval", "-1"), indices);
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
public ActionFuture<UpdateSettingsResponse> setRefreshInterval(String refreshInterval, String... indices) {
    logger.trace("Set refresh to {} on {}", refreshInterval, Arrays.asList(indices));
    return updateSettings(Collections.singletonMap("refresh_interval", refreshInterval), indices);
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
public ActionFuture<UpdateSettingsResponse> disableReplicas(String... indices) {
    logger.trace("Disabling replicas on {}", Arrays.asList(indices));
    return updateSettings(Collections.singletonMap("number_of_replicas", "0"), indices);
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
public ActionFuture<UpdateSettingsResponse> setReplicas(int replicas, String... indices) {
    logger.trace("Set replicas to {} on {}", replicas, Arrays.asList(indices));
    return updateSettings(Collections.singletonMap("number_of_replicas", String.valueOf(replicas)), indices);
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
public ActionFuture<UpdateSettingsResponse> updateSettings(Map<String, String> settings, String... indices) {
    logger.trace("Update settings with {} on {}", settings, Arrays.asList(indices));
    return client.admin().indices()
            .updateSettings(Requests.updateSettingsRequest(indices)
                    .settings(settings));
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
public ActionFuture<UpdateSettingsResponse> putSettings(String settingsSource, String index) {
    logger.trace("Put settings with {} on {}", settingsSource, index);
    return client.admin().indices()
            .updateSettings(Requests.updateSettingsRequest(index)
                    .settings(settingsSource));
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
public void updateSettings(String index, String settings) throws Exception {
  UpdateSettingsRequestBuilder builder = client.admin().indices().prepareUpdateSettings(index);
  builder.setSettings(settings);
  UpdateSettingsResponse response = builder.execute().actionGet();
}
 

import org.elasticsearch.action.admin.indices.settings.put.UpdateSettingsResponse; //导入依赖的package包/类
/**
 * Updates settings of one or more indices.
 *
 * @param request the update settings request
 * @return The result future
 */
ActionFuture<UpdateSettingsResponse> updateSettings(UpdateSettingsRequest request);