File tree Expand file tree Collapse file tree 2 files changed +14
-14
lines changed
server/src/main/java/org/elasticsearch/rest/action/admin/indices Expand file tree Collapse file tree 2 files changed +14
-14
lines changed Original file line number Diff line number Diff line change @@ -45,12 +45,12 @@ public String getName() {
4545
4646 @ Override
4747 public RestChannelConsumer prepareRequest (final RestRequest request , final NodeClient client ) throws IOException {
48- ResizeRequest shrinkIndexRequest = new ResizeRequest (request .param ("target" ), request .param ("index" ));
49- shrinkIndexRequest .setResizeType (ResizeType .SHRINK );
50- request .applyContentParser (shrinkIndexRequest ::fromXContent );
51- shrinkIndexRequest .timeout (request .paramAsTime ("timeout" , shrinkIndexRequest .timeout ()));
52- shrinkIndexRequest .masterNodeTimeout (request .paramAsTime ("master_timeout" , shrinkIndexRequest .masterNodeTimeout ()));
53- shrinkIndexRequest .setWaitForActiveShards (ActiveShardCount .parseString (request .param ("wait_for_active_shards" )));
54- return channel -> client .admin ().indices ().resizeIndex (shrinkIndexRequest , new RestToXContentListener <>(channel ));
48+ final ResizeRequest resizeRequest = new ResizeRequest (request .param ("target" ), request .param ("index" ));
49+ resizeRequest .setResizeType (ResizeType .SHRINK );
50+ request .applyContentParser (resizeRequest ::fromXContent );
51+ resizeRequest .timeout (request .paramAsTime ("timeout" , resizeRequest .timeout ()));
52+ resizeRequest .masterNodeTimeout (request .paramAsTime ("master_timeout" , resizeRequest .masterNodeTimeout ()));
53+ resizeRequest .setWaitForActiveShards (ActiveShardCount .parseString (request .param ("wait_for_active_shards" )));
54+ return channel -> client .admin ().indices ().resizeIndex (resizeRequest , new RestToXContentListener <>(channel ));
5555 }
5656}
Original file line number Diff line number Diff line change @@ -45,12 +45,12 @@ public String getName() {
4545
4646 @ Override
4747 public RestChannelConsumer prepareRequest (final RestRequest request , final NodeClient client ) throws IOException {
48- ResizeRequest shrinkIndexRequest = new ResizeRequest (request .param ("target" ), request .param ("index" ));
49- shrinkIndexRequest .setResizeType (ResizeType .SPLIT );
50- request .applyContentParser (shrinkIndexRequest ::fromXContent );
51- shrinkIndexRequest .timeout (request .paramAsTime ("timeout" , shrinkIndexRequest .timeout ()));
52- shrinkIndexRequest .masterNodeTimeout (request .paramAsTime ("master_timeout" , shrinkIndexRequest .masterNodeTimeout ()));
53- shrinkIndexRequest .setWaitForActiveShards (ActiveShardCount .parseString (request .param ("wait_for_active_shards" )));
54- return channel -> client .admin ().indices ().resizeIndex (shrinkIndexRequest , new RestToXContentListener <>(channel ));
48+ final ResizeRequest resizeRequest = new ResizeRequest (request .param ("target" ), request .param ("index" ));
49+ resizeRequest .setResizeType (ResizeType .SPLIT );
50+ request .applyContentParser (resizeRequest ::fromXContent );
51+ resizeRequest .timeout (request .paramAsTime ("timeout" , resizeRequest .timeout ()));
52+ resizeRequest .masterNodeTimeout (request .paramAsTime ("master_timeout" , resizeRequest .masterNodeTimeout ()));
53+ resizeRequest .setWaitForActiveShards (ActiveShardCount .parseString (request .param ("wait_for_active_shards" )));
54+ return channel -> client .admin ().indices ().resizeIndex (resizeRequest , new RestToXContentListener <>(channel ));
5555 }
5656}
You can’t perform that action at this time.
0 commit comments