Java之ES批量处理

浅浅的花香味﹌ 2021-09-23 08:56 932阅读 0赞

趁着有时间，下面来继续记录并分享ES相关：

具体实现如下所示：

/**
    *	create by wxy_jdhk
    */
    public class ElasticSearchUtils {
    	//批量处理
    	public void getBulkProcessor(TransportClient client) {
    		BulkProcessor bulkProcessor = BulkProcessor.builder(
    				client, //es 客户端
    				new BulkProcessor.Listener() {
    					//在bulk执行时调用
    					public void beforeBulk(long arg0, BulkRequest arg1) {
    						// TODO Auto-generated method stub
    						
    					}
    					//在bulk失败或异常时调用
    					public void afterBulk(long arg0, BulkRequest arg1, Throwable arg2) {
    						// TODO Auto-generated method stub
    						
    					}
    					//在bulk异常之后执行
    					public void afterBulk(long arg0, BulkRequest arg1, BulkResponse arg2) {
    						// TODO Auto-generated method stub
    						
    					}
    				})
    				//每10000次请求执行一次bulk
    				.setBulkActions(10000)
    				//每5mb刷新一次bulk
    				.setBulkSize(new ByteSizeValue(5, ByteSizeUnit.MB))
    				//每5秒钟刷新一次
    				.setFlushInterval(TimeValue.timeValueSeconds(5))
    				//0：只允许一个请求执行
    				//1：允许创建新的请求
    				.setConcurrentRequests(1)
    				.setBackoffPolicy(
    						BackoffPolicy.exponentialBackoff(TimeValue.timeValueMillis(100), 3)
    				).build();
    		//向iBulkProcessor添加示例
    		bulkProcessor.add(new DeleteRequest("twitter", "_doc", "2"));
    		//关闭批量处理
    		try {
    			bulkProcessor.awaitClose(10, TimeUnit.MINUTES);
    		} catch (InterruptedException e) {
    			e.printStackTrace();
    		}
    		bulkProcessor.close();
    	}
    }

发表评论取消回复

表情：

评论列表（有 0 条评论，932人围观）

还没有评论，来说两句吧...

相关阅读

相关 Elasticsearch(037)：es中批量操作之bulk

一、bulk概述 1.1 bulk的基础概念 `bulk`是`es`提供的一种`批量增删改`的操作API。 1.2 bulk的语法 `bulk`对`JSON

￡神魔★判官ぃ/ 2022年12月17日 08:50/ 0 赞/ 651 阅读

相关 Elasticsearch(036)：es中批量操作之mget(批量查询)

mget(批量查询) 一、介绍 `mget`是`es`提供的一种批量的读取操作的API。 `mget` API允许根据索引，`类型（可选）`和`id（以及可能的路

分手后的思念是犯贱/ 2022年12月17日 05:27/ 0 赞/ 469 阅读

相关 Hibernate学习之批量处理

测试环境： windows8 MySQL5.6 Hibernate3 Hibernate批量插入使用 Hibernate 将一百万条记录插入到数据库的一个很天

柔光的暖阳◎/ 2022年08月08日 00:44/ 0 赞/ 100 阅读

相关 ES：mget批量查询

1.批量查询的好处 1）一条一条查询，需要发送多次，网络开销大，批量查询可以解决很多网络的开销 2）使用mget 2.使用mget进行查询操作 1）如果批量查询的对象不

素颜马尾好姑娘i/ 2022年05月28日 06:58/ 0 赞/ 159 阅读

相关 es mget批量查询

批量查询的好处就是一条一条的查询，比如说要查询100条数据，那么就要发送100次网络请求，这个开销还是很大的，如果进行批量查询的话，查询100条数据，就只要发送1次

待我称王封你为后i/ 2022年05月13日 11:22/ 0 赞/ 211 阅读

相关 java批量执行之分批处理

相关：在处理一些与数据库相关的操作的时候，通常把一些操作合并能够起到优化的效果，并且数量越大，批量执行的效率比一条一条执行的效率要快的多。批量插入比单次插入快比

比眉伴天荒/ 2022年05月12日 06:54/ 0 赞/ 187 阅读

相关 es 之批量处理 bulk api

简介说明：The bulk API makes it possible to perform many index/delete operations in a

忘是亡心i/ 2022年04月23日 08:52/ 0 赞/ 389 阅读

相关 Docker之批量处理骚操作！

> 杀死所有正在运行的容器 > docker kill $(docker ps -a -q) > 删除所有已经停止的容器 > docker rm $(docker

刺骨的言语ヽ痛彻心扉/ 2022年04月23日 02:54/ 0 赞/ 165 阅读

相关 ElasticSearch(ES)JAVA批量更新批量插入——就一步

注：此Es处理方式是基于Spring-data 集成的 1. 批量更新 public void allChangeCart(CartsSearchDTO ca

男娘i/ 2021年12月04日 00:41/ 0 赞/ 1647 阅读

相关 Java之ES批量处理

趁着有时间，下面来继续记录并分享ES相关：具体实现如下所示： / create by wxy_jdhk / public class E

浅浅的花香味﹌/ 2021年09月23日 08:56/ 0 赞/ 933 阅读