honeymoose
/
OpenSearch
mirror of https://github.com/honeymoose/OpenSearch.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[ML] Reuse encapsulated delete-by-query request 

Original commit: elastic/x-pack-elasticsearch@cc0f2ce815
This commit is contained in:
Dimitrios Athanasiou 2017-05-03 14:58:22 +01:00
parent 3f73748d14
commit d140b3028d
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
plugin/src/main/java/org/elasticsearch/xpack/ml/job/persistence/JobDataDeleter.java
View File

@ -105,18 +105,16 @@ public class JobDataDeleter {
* Delete all results marked as interim
*/
public void deleteInterimResults() {
SearchRequest searchRequest = new SearchRequest(AnomalyDetectorsIndex.jobResultsAliasedName(jobId));
DeleteByQueryRequest request = new DeleteByQueryRequest(searchRequest);
request.setRefresh(false);
request.setSlices(5);
DeleteByQueryHolder deleteByQueryHolder = new DeleteByQueryHolder(AnomalyDetectorsIndex.jobResultsAliasedName(jobId));
deleteByQueryHolder.dbqRequest.setRefresh(false);
searchRequest.indicesOptions(IndicesOptions.lenientExpandOpen());
searchRequest.types(Result.TYPE.getPreferredName());
deleteByQueryHolder.searchRequest.indicesOptions(IndicesOptions.lenientExpandOpen());
deleteByQueryHolder.searchRequest.types(Result.TYPE.getPreferredName());
QueryBuilder qb = QueryBuilders.termQuery(Bucket.IS_INTERIM.getPreferredName(), true);
searchRequest.source(new SearchSourceBuilder().query(new ConstantScoreQueryBuilder(qb)));
deleteByQueryHolder.searchRequest.source(new SearchSourceBuilder().query(new ConstantScoreQueryBuilder(qb)));
try {
client.execute(XPackDeleteByQueryAction.INSTANCE, request).get();
client.execute(XPackDeleteByQueryAction.INSTANCE, deleteByQueryHolder.dbqRequest).get();
} catch (Exception e) {
LOGGER.error("[" + jobId + "] An error occurred while deleting interim results", e);
}