栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 前沿技术 > 大数据 > 大数据系统

ES写入四大模式:INDEX、CREATE、UPDATE、DOC

ES写入四大模式:INDEX、CREATE、UPDATE、DOC

四大模式区别: INDEX:

这个模式下,可以采用es内部生成id的方式,使得每次写入都是新增数据,因为每一次的id都不同

CREATE:

需要指定id,如果id已存在,则该条数据写入失败(被丢弃)

UPDATE:

需要指定id,如果id已存在,覆盖原有数据

UPDAET --OPTION: DOC_AS_UPSERT

需要指定id,如果id已存在,以UPSERT的方式更新数据,而不是直接覆盖原有数据。

Java API
// index
requestIndexer.add(Requests.indexRequest().index(index).type(type).source(jsonObject));
// create
requestIndexer.add(Requests.indexRequest().create(true).index(index).id(id).type(type).source(jsonObject));
// update
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.index(index).id(id).type(type).doc(jsonObject);
requestIndexer.add(updateRequest);
//doc_as_upsert
UpdateRequest updateRequest = new UpdateRequest();
updateRequest.index(index).id(id).type(type).doc(jsonObject);
requestIndexer.add(updateRequest);

 @Override
    public void add(UpdateRequest... updateRequests) {
        UpdateRequest[] var2 = updateRequests;
        int var3 = updateRequests.length;
        for(int var4 = 0; var4 < var3; ++var4) {
            UpdateRequest updateRequest = var2[var4];
            if (this.flushOnCheckpoint) {
                this.numPendingRequestsRef.getAndIncrement();
            }
            this.bulkProcessor.add(updateRequest.docAsUpsert(true));
        }
    }
转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/281186.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号