elasticsearch java api 增删改 操作
Elasticsearch • qq123 发表了文章 • 0 个评论 • 6994 次浏览 • 2016-06-08 16:06
IndexRequestBuilder requestBuilder = null;
requestBuilder = client.prepareIndex(index, type, key).setRefresh(false);
requestBuilder.setSource(value).get();
--批量数据
BulkRequestBuilder bulkRequest = null;
bulkRequest = client.prepareBulk();
for (Map.Entry<String, Object> map : doc.entrySet()) {
bulkRequest.add(client.prepareIndex(index, type, map.getKey())
.setSource(CouchbaseUtil.GJSON.toJson(map.getValue())).setRefresh(false));
}
bulkRequest.get();
bulkRequest.request().requests().clear();
--更新数据
client.prepareUpdate().setIndex(index).setType(type).setId(id).setDoc(map).get();
--批量删除数据
BulkRequestBuilder bulk = null;
bulk = client.prepareBulk();
for (String id : ids) {
bulk.add(client.prepareDelete().setIndex(index).setType(type).setId(id));
}
bulk.get();
elasticsearch java api 增删改 操作
回复Elasticsearch • qq123 发起了问题 • 1 人关注 • 0 个回复 • 4797 次浏览 • 2016-06-08 16:03
elasticsearch遍历所有数据集
Elasticsearch • qq123 发表了文章 • 0 个评论 • 9594 次浏览 • 2016-06-08 15:00
SearchResponse searchResponse = esClient.prepareSearch("index")
.setTypes("type")
.setSize(10000)
//这个游标维持多长时间
.setScroll(TimeValue.timeValueMinutes(8))
.execute().actionGet();
System.out.println(searchResponse.getHits().getTotalHits());
while(true){
for (SearchHit hit : searchResponse.getHits()) {
System.out.println(hit.getSourceAsString()));
}
searchResponse = esClient.prepareSearchScroll(searchResponse.getScrollId())
.setScroll(TimeValue.timeValueMinutes(8))
.execute().actionGet();
if (searchResponse.getHits().getHits().length == 0) {
break;
}
}
问下elasticsearch中如何查出如何数据格式
Elasticsearch • qq123 回复了问题 • 2 人关注 • 1 个回复 • 4004 次浏览 • 2016-06-12 11:05
ES旧master节点启动,数据丢失,为何不同步新主节点数据?
回复Elasticsearch • ZhaoYong 回复了问题 • 2 人关注 • 1 个回复 • 8860 次浏览 • 2016-06-07 18:54
Java 调用es sdk bulk数据 cpu过高
Elasticsearch • flowaters 回复了问题 • 2 人关注 • 1 个回复 • 5066 次浏览 • 2016-06-14 12:02
elasticsearch 对同一索引进行检索 多次刷新会出现同一条件不同结果
Elasticsearch • nodexy 回复了问题 • 2 人关注 • 2 个回复 • 4789 次浏览 • 2016-06-06 15:20
logstash output数据到带有kerberos验证的HDFS上
Logstash • sanshi123 回复了问题 • 5 人关注 • 3 个回复 • 8488 次浏览 • 2021-04-07 17:20
logstash 如何将一个时间戳字段 ,转换一个新字段仅包含:年月日,
Logstash • joeywen 回复了问题 • 2 人关注 • 1 个回复 • 7021 次浏览 • 2016-06-06 15:31
elasticsearch字段存储的内容有长度限制吧 字符太长好像是写不进去?
Elasticsearch • martindu 回复了问题 • 3 人关注 • 1 个回复 • 12510 次浏览 • 2016-06-04 13:48
使用别名查询多个索引的效率?
Elasticsearch • hufuman 回复了问题 • 5 人关注 • 3 个回复 • 9494 次浏览 • 2019-07-29 11:41
请教一下ES搜索排序的问题。
Elasticsearch • smile_sunshine 回复了问题 • 4 人关注 • 4 个回复 • 7160 次浏览 • 2016-06-21 20:27
负载均衡用的master节点内存需要给很大吗
Elasticsearch • joeywen 回复了问题 • 3 人关注 • 1 个回复 • 5053 次浏览 • 2016-06-03 15:18
index_not_found_exception
Elasticsearch • helinyu 回复了问题 • 3 人关注 • 2 个回复 • 15213 次浏览 • 2019-08-15 11:10
elasticsearch如何句部更新?
Elasticsearch • qq123 回复了问题 • 3 人关注 • 4 个回复 • 4222 次浏览 • 2016-06-03 18:24