Makes DeleteByQueryRequest implements CompositeIndicesRequest

This commit is contained in:
Tanguy Leroux 2016-05-19 17:13:35 +02:00
parent b40628d4e8
commit bf41ac8bf2
1 changed files with 15 additions and 1 deletions

View File

@ -20,7 +20,9 @@
package org.elasticsearch.index.reindex; package org.elasticsearch.index.reindex;
import org.elasticsearch.action.ActionRequestValidationException; import org.elasticsearch.action.ActionRequestValidationException;
import org.elasticsearch.action.IndicesRequest;
import org.elasticsearch.action.search.SearchRequest; import org.elasticsearch.action.search.SearchRequest;
import org.elasticsearch.action.support.IndicesOptions;
import static org.elasticsearch.action.ValidateActions.addValidationError; import static org.elasticsearch.action.ValidateActions.addValidationError;
@ -41,7 +43,7 @@ import static org.elasticsearch.action.ValidateActions.addValidationError;
* <li>it's results won't be visible until the index is refreshed.</li> * <li>it's results won't be visible until the index is refreshed.</li>
* </ul> * </ul>
*/ */
public class DeleteByQueryRequest extends AbstractBulkByScrollRequest<DeleteByQueryRequest> { public class DeleteByQueryRequest extends AbstractBulkByScrollRequest<DeleteByQueryRequest> implements IndicesRequest {
public DeleteByQueryRequest() { public DeleteByQueryRequest() {
} }
@ -76,4 +78,16 @@ public class DeleteByQueryRequest extends AbstractBulkByScrollRequest<DeleteByQu
searchToString(b); searchToString(b);
return b.toString(); return b.toString();
} }
@Override
public String[] indices() {
assert getSearchRequest() != null;
return getSearchRequest().indices();
}
@Override
public IndicesOptions indicesOptions() {
assert getSearchRequest() != null;
return getSearchRequest().indicesOptions();
}
} }