Skip to content

Commit 16ed69d

Browse files
committed
add routing to delete by query rest endpoint
1 parent cf4f6de commit 16ed69d

File tree

1 file changed

+1
-0
lines changed

1 file changed

+1
-0
lines changed

modules/elasticsearch/src/main/java/org/elasticsearch/rest/action/deletebyquery/RestDeleteByQueryAction.java

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -70,6 +70,7 @@ public class RestDeleteByQueryAction extends BaseRestHandler {
7070
deleteByQueryRequest.types(splitTypes(request.param("type")));
7171
deleteByQueryRequest.timeout(request.paramAsTime("timeout", ShardDeleteByQueryRequest.DEFAULT_TIMEOUT));
7272

73+
deleteByQueryRequest.routing(request.param("routing"));
7374
String replicationType = request.param("replication");
7475
if (replicationType != null) {
7576
deleteByQueryRequest.replicationType(ReplicationType.fromString(replicationType));

0 commit comments

Comments
 (0)