|
|
|
package com.yoho.datasync.fullsync.service.impl;
|
|
|
|
import org.elasticsearch.script.Script;
|
|
|
|
import org.elasticsearch.tasks.TaskId;
|
|
|
|
import org.elasticsearch.action.support.WriteRequest.RefreshPolicy;
|
|
|
|
|
|
|
|
|
|
|
|
import com.alibaba.fastjson.JSON;
|
|
...
|
...
|
@@ -9,15 +6,11 @@ import org.elasticsearch.action.delete.DeleteRequest; |
|
|
|
import org.elasticsearch.action.delete.DeleteResponse;
|
|
|
|
import org.elasticsearch.action.search.SearchRequest;
|
|
|
|
import org.elasticsearch.action.search.SearchResponse;
|
|
|
|
import org.elasticsearch.action.update.UpdateRequest;
|
|
|
|
import org.elasticsearch.index.query.BoolQueryBuilder;
|
|
|
|
import org.elasticsearch.index.query.QueryBuilder;
|
|
|
|
import org.elasticsearch.index.query.QueryBuilders;
|
|
|
|
import org.elasticsearch.index.reindex.BulkByScrollResponse;
|
|
|
|
import org.elasticsearch.index.reindex.DeleteByQueryRequest;
|
|
|
|
import org.elasticsearch.search.builder.SearchSourceBuilder;
|
|
|
|
import org.elasticsearch.search.sort.SortBuilders;
|
|
|
|
import org.elasticsearch.search.sort.SortOrder;
|
|
|
|
import org.springframework.data.domain.PageRequest;
|
|
|
|
import org.springframework.data.domain.Pageable;
|
|
|
|
import com.yoho.datasync.fullsync.dal.repository.yhcommunity.model.UserInfo;
|
...
|
...
|
|
