org.elasticsearch.client.IndicesAdminClient.prepareGetSettings()方法的使用及代码示例

x33g5p2x  于2022-01-20 转载在 其他  
字(4.6k)|赞(0)|评价(0)|浏览(94)

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

IndicesAdminClient.prepareGetSettings介绍

[英]Returns a builder for a per index settings get request.
[中]返回每个索引设置get请求的生成器。

代码示例

代码示例来源:origin: SonarSource/sonarqube

@Override
void beforeStart(BulkIndexer bulkIndexer) {
 this.progress = new ProgressLogger(format("Progress[BulkIndexer[%s]]", bulkIndexer.indexType.getIndex()), bulkIndexer.result.total, LOGGER)
  .setPluralLabel("requests");
 this.progress.start();
 Map<String, Object> temporarySettings = new HashMap<>();
 GetSettingsResponse settingsResp = bulkIndexer.client.nativeClient().admin().indices().prepareGetSettings(bulkIndexer.indexType.getIndex()).get();
 // deactivate replicas
 int initialReplicas = Integer.parseInt(settingsResp.getSetting(bulkIndexer.indexType.getIndex(), IndexMetaData.SETTING_NUMBER_OF_REPLICAS));
 if (initialReplicas > 0) {
  initialSettings.put(IndexMetaData.SETTING_NUMBER_OF_REPLICAS, initialReplicas);
  temporarySettings.put(IndexMetaData.SETTING_NUMBER_OF_REPLICAS, 0);
 }
 // deactivate periodical refresh
 String refreshInterval = settingsResp.getSetting(bulkIndexer.indexType.getIndex(), REFRESH_INTERVAL_SETTING);
 initialSettings.put(REFRESH_INTERVAL_SETTING, refreshInterval);
 temporarySettings.put(REFRESH_INTERVAL_SETTING, "-1");
 updateSettings(bulkIndexer, temporarySettings);
}

代码示例来源:origin: SonarSource/sonarqube

private int replicas() {
 GetSettingsResponse settingsResp = es.client().nativeClient().admin().indices()
  .prepareGetSettings(INDEX).get();
 return Integer.parseInt(settingsResp.getSetting(INDEX, IndexMetaData.SETTING_NUMBER_OF_REPLICAS));
}

代码示例来源:origin: com.github.cafdataprocessing/corepolicy-condition-engine

private boolean canGetSettings() throws UnknownHostException {
  GetSettingsResponse indicesResponse = getElasticClient()
      .admin()
      .indices()
      .prepareGetSettings(policyIndexName)
      .setMasterNodeTimeout(elasticsearchProperties.getElasticsearchMasterNodeTimeout())
      .get();
  if (indicesResponse.getIndexToSettings().isEmpty()) {
    logger.warn("Failed to retrieve settings for the configured Elasticsearch index {}", policyIndexName);
    return false;
  }
  return true;
}

代码示例来源:origin: org.eclipse.kapua/kapua-datastore-client-transport

@Override
public IndexResponse findIndexes(IndexRequest indexRequest) throws ClientException {
  checkClient();
  try {
    GetSettingsResponse response = esClientProvider.getClient().admin().indices().prepareGetSettings(indexRequest.getIndex())
        .get(getQueryTimeout());
    List<String> list = new ArrayList<>();
    response.getIndexToSettings().keysIt().forEachRemaining(list::add);
    return new IndexResponse(list.toArray(new String[list.size()]));
  }
  catch (IndexNotFoundException e) {
    return new IndexResponse(new String[0]);
  }
}

代码示例来源:origin: eclipse/kapua

@Override
public IndexResponse findIndexes(IndexRequest indexRequest) throws ClientException {
  checkClient();
  try {
    GetSettingsResponse response = esClientProvider.getClient().admin().indices().prepareGetSettings(indexRequest.getIndex())
        .get(getQueryTimeout());
    List<String> list = new ArrayList<>();
    response.getIndexToSettings().keysIt().forEachRemaining(list::add);
    return new IndexResponse(list.toArray(new String[list.size()]));
  }
  catch (IndexNotFoundException e) {
    return new IndexResponse(new String[0]);
  }
}

代码示例来源:origin: org.sonarsource.sonarqube/sonar-server

@Override
void beforeStart(BulkIndexer bulkIndexer) {
 this.progress = new ProgressLogger(format("Progress[BulkIndexer[%s]]", bulkIndexer.indexType.getIndex()), bulkIndexer.result.total, LOGGER)
  .setPluralLabel("requests");
 this.progress.start();
 Map<String, Object> temporarySettings = new HashMap<>();
 GetSettingsResponse settingsResp = bulkIndexer.client.nativeClient().admin().indices().prepareGetSettings(bulkIndexer.indexType.getIndex()).get();
 // deactivate replicas
 int initialReplicas = Integer.parseInt(settingsResp.getSetting(bulkIndexer.indexType.getIndex(), IndexMetaData.SETTING_NUMBER_OF_REPLICAS));
 if (initialReplicas > 0) {
  initialSettings.put(IndexMetaData.SETTING_NUMBER_OF_REPLICAS, initialReplicas);
  temporarySettings.put(IndexMetaData.SETTING_NUMBER_OF_REPLICAS, 0);
 }
 // deactivate periodical refresh
 String refreshInterval = settingsResp.getSetting(bulkIndexer.indexType.getIndex(), REFRESH_INTERVAL_SETTING);
 initialSettings.put(REFRESH_INTERVAL_SETTING, refreshInterval);
 temporarySettings.put(REFRESH_INTERVAL_SETTING, "-1");
 updateSettings(bulkIndexer, temporarySettings);
}

相关文章

微信公众号

最新文章

更多

IndicesAdminClient类方法