本文整理了Java中org.elasticsearch.client.IndicesAdminClient.prepareGetSettings()
方法的一些代码示例,展示了IndicesAdminClient.prepareGetSettings()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。IndicesAdminClient.prepareGetSettings()
方法的具体详情如下:
包路径:org.elasticsearch.client.IndicesAdminClient
类名称: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);
}
内容来源于网络,如有侵权,请联系作者删除!