org.elasticsearch.index.reindex

Class RethrottleRequestBuilder

java.lang.Object

org.elasticsearch.action.ActionRequestBuilder<Request,Response,RequestBuilder>

org.elasticsearch.action.support.tasks.TasksRequestBuilder<RethrottleRequest,ListTasksResponse,RethrottleRequestBuilder>

org.elasticsearch.index.reindex.RethrottleRequestBuilder

public class RethrottleRequestBuilder
extends TasksRequestBuilder<RethrottleRequest,ListTasksResponse,RethrottleRequestBuilder>

Java API support for changing the throttle on reindex tasks while they are running.

Field Summary

Fields inherited from class org.elasticsearch.action.ActionRequestBuilder

action, client, request

Constructor Summary

Constructors

Constructor and Description
RethrottleRequestBuilder(ElasticsearchClient client, Action<RethrottleRequest,ListTasksResponse,RethrottleRequestBuilder> action)

Method Summary

Methods

Modifier and Type	Method and Description
RethrottleRequestBuilder	setRequestsPerSecond(float requestsPerSecond) Set the throttle to apply to all matching requests in sub-requests per second.

Methods inherited from class org.elasticsearch.action.support.tasks.TasksRequestBuilder

setActions, setNodesIds, setTimeout

Methods inherited from class org.elasticsearch.action.ActionRequestBuilder

beforeExecute, execute, execute, get, get, get, putHeader, request

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RethrottleRequestBuilder

public RethrottleRequestBuilder(ElasticsearchClient client,
                        Action<RethrottleRequest,ListTasksResponse,RethrottleRequestBuilder> action)

Method Detail

setRequestsPerSecond

public RethrottleRequestBuilder setRequestsPerSecond(float requestsPerSecond)

Set the throttle to apply to all matching requests in sub-requests per second. Float.POSITIVE_INFINITY means set no throttle. Throttling is done between batches, as we start the next scroll requests. That way we can increase the scroll's timeout to make sure that it contains any time that we might wait.