我又一個(gè)問題請(qǐng)教一下啊窃蹋,我現(xiàn)在就是用的這種同步方法,貼上我的部分代碼:
if(i%1000==0 || i == queryList.size()-1){
System.out.println(i);
bulkResponse = restHighLevelClient.bulk(request, RequestOptions.DEFAULT);
request = new BulkRequest();
//logger.info("當(dāng)前處理到第:"+i+"條");
}
我是這樣做了一份分批處理趁俊,先把參數(shù)通過request.add 加到request里面,但是一批數(shù)據(jù)同步完了之后刑然,怎么才能把這個(gè)request清空呢寺擂,如果不清空,數(shù)據(jù)就會(huì)累加
Elasticsearch bulk request2018-12-22 最近在往ES里寫數(shù)據(jù)的時(shí)候泼掠,發(fā)現(xiàn)一條一條寫非常慢沽讹。基本一個(gè)比較小規(guī)模(3master武鲁、3data爽雄、1client)的ES集群on k8s,用RestHi...