elasticsearch java api 增删改 操作

Elasticsearchqq123 发表了文章 • 0 个评论 • 1456 次浏览 • 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(); 查看全部
--添加数据
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 增删改 操作

回复

Elasticsearchqq123 发起了问题 • 1 人关注 • 0 个回复 • 536 次浏览 • 2016-06-08 16:03 • 来自相关话题

elasticsearch遍历所有数据集

Elasticsearchqq123 发表了文章 • 0 个评论 • 1026 次浏览 • 2016-06-08 15:00 • 来自相关话题

    BoolQueryBuilder bool=QueryBuilders.boolQuery();
        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;
            }
        } 查看全部
    BoolQueryBuilder bool=QueryBuilders.boolQuery();
        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;
            }
        }

logstash output数据到带有kerberos验证的HDFS上

回复

Logstashwu 发起了问题 • 1 人关注 • 0 个回复 • 660 次浏览 • 2016-06-06 11:19 • 来自相关话题

range 未报错误却没有结果【已解决】

回复

Elasticsearchfreefrozen 发起了问题 • 0 人关注 • 0 个回复 • 350 次浏览 • 2016-06-01 16:01 • 来自相关话题

关于index创建时性能问题

回复

ElasticsearchBroA 发起了问题 • 1 人关注 • 0 个回复 • 449 次浏览 • 2016-05-31 11:39 • 来自相关话题

es pinyin分词器如何处理多音字问题???

回复

Elasticsearchkb 发起了问题 • 1 人关注 • 0 个回复 • 431 次浏览 • 2016-05-30 13:49 • 来自相关话题

ElasticSearch 2.x java client 如何从SearchResponse中获取_routing

回复

Elasticsearchlilin 发起了问题 • 1 人关注 • 0 个回复 • 1211 次浏览 • 2016-05-27 20:01 • 来自相关话题

如何修改filed数据类型?

回复

默认分类modernist 发起了问题 • 1 人关注 • 0 个回复 • 938 次浏览 • 2016-05-27 15:29 • 来自相关话题

kibana时间匹配

回复

Kibana匿名用户 发起了问题 • 1 人关注 • 0 个回复 • 708 次浏览 • 2016-05-27 10:26 • 来自相关话题