博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
ElasticSearch(八) Bulk API
阅读量:5300 次
发布时间:2019-06-14

本文共 1112 字,大约阅读时间需要 3 分钟。

import static org.elasticsearch.common.xcontent.XContentFactory.*;BulkRequestBuilder bulkRequest = client.prepareBulk();// either use client#prepare, or use Requests# to directly build index/delete requestsbulkRequest.add(client.prepareIndex("twitter", "tweet", "1")        .setSource(jsonBuilder()                    .startObject()                        .field("user", "kimchy")                        .field("postDate", new Date())                        .field("message", "trying out Elasticsearch")                    .endObject()                  )        );bulkRequest.add(client.prepareIndex("twitter", "tweet", "2")        .setSource(jsonBuilder()                    .startObject()                        .field("user", "kimchy")                        .field("postDate", new Date())                        .field("message", "another post")                    .endObject()                  )        );BulkResponse bulkResponse = bulkRequest.get();if (bulkResponse.hasFailures()) {    // process failures by iterating through each bulk response item}

转载于:https://www.cnblogs.com/xiaocandou/p/8118901.html

你可能感兴趣的文章
关于HostnameVerifier接口的解读
查看>>
Swift的闭包
查看>>
关于session_cache_expire 的理解
查看>>
lock和synchronized如何选择?
查看>>
decltype
查看>>
抽象类
查看>>
C++面向对象基础知识
查看>>
PY----Python
查看>>
[转载]识别真假搜索引擎(搜索蜘蛛)方法
查看>>
如何查看linux服务器内存使用情况
查看>>
Charles 3断点篡改数据
查看>>
虚拟机安装iOS开发环境流水帐,附iOS Developer Program流水帐
查看>>
[HNOI2010]CITY 城市建设
查看>>
网站出现service unavailable的解决方法
查看>>
c# 添加注册表
查看>>
MD5解密
查看>>
缩放文本框ExpandTextView
查看>>
Android 开发工具推荐
查看>>
enum值与string的转换
查看>>
c#基础知识
查看>>