赞
踩
设置全局分片数量:
put http://196.168.137.100:19085/_template/template_http_request_record
{
“index_patterns”: ["*"],
“settings”: {
“number_of_shards”: 5,
“number_of_replicas”: 1
}
}
指定创建索引时的分片数量:
put http://196.168.137.100:19085/<索引名称>
{
“settings”: {
“number_of_shards”: 12,
“number_of_replicas”: 1
}
}
client7.4.0创建索引时,指定主副分片
<dependency>
<groupId>org.elasticsearch</groupId>
<artifactId>elasticsearch</artifactId>
<version>7.4.0</version>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-client</artifactId>
<version>7.4.0</version>
</dependency>
<dependency>
<groupId>org.elasticsearch.client</groupId>
<artifactId>elasticsearch-rest-high-level-client</artifactId>
<version>7.4.0</version>
</dependency>
代码:
//创建索引
CreateIndexRequest createIndexRequest = new CreateIndexRequest(“index”);
//设置分片
createIndexRequest.settings(
Settings.builder().put("index.number_of_shards", 5)
.put("index.number_of_replicas", 3));
//同步响应
CreateIndexResponse createIndexResponse = client.indices().create(createIndexRequest, RequestOptions.DEFAULT);
boolean acknowledged = createIndexResponse.isAcknowledged();
boolean shardsAcknowledged = createIndexResponse.isShardsAcknowledged();
if (acknowledged && shardsAcknowledged) {
System.out.println(indexName + "索引创建成功");
} else {
throw new Exception("索引创建失败");
}
Copyright © 2003-2013 www.wpsshop.cn 版权所有,并保留所有权利。