|
@ -78,7 +78,6 @@ public class ElastricSearchSave {
|
|
for (SaveModel obj : sms) {
|
|
for (SaveModel obj : sms) {
|
|
try {
|
|
try {
|
|
JSONObject jo=new JSONObject();
|
|
JSONObject jo=new JSONObject();
|
|
obj.setCreateTime(new Date());
|
|
|
|
jo.put("doc",obj);
|
|
jo.put("doc",obj);
|
|
Update index = new Update.Builder(jo.toString()).index(esIndex).type(esType).id(obj.getId()).build();
|
|
Update index = new Update.Builder(jo.toString()).index(esIndex).type(esType).id(obj.getId()).build();
|
|
bulk.addAction(index);
|
|
bulk.addAction(index);
|