我又一個(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...