Skip to content

Commit 46e8d97

Browse files
authored
Core: Remove RequestBuilder from Action (#30966)
This commit removes the RequestBuilder generic type from Action. It was needed to be used by the newRequest method, which in turn was used by client.prepareExecute. Both of these methods are now removed, along with the existing users of prepareExecute constructing the appropriate builder directly.
1 parent 0f5e570 commit 46e8d97

File tree

318 files changed

+509
-1747
lines changed

Some content is hidden

Large Commits have some content hidden by default. Use the searchbox below for content that may be hidden.

318 files changed

+509
-1747
lines changed

client/benchmark/src/main/java/org/elasticsearch/client/benchmark/transport/TransportClientBenchmark.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -79,7 +79,7 @@ private static final class TransportBulkRequestExecutor implements BulkRequestEx
7979

8080
@Override
8181
public boolean bulkIndex(List<String> bulkData) {
82-
NoopBulkRequestBuilder builder = NoopBulkAction.INSTANCE.newRequestBuilder(client);
82+
NoopBulkRequestBuilder builder = new NoopBulkRequestBuilder(client,NoopBulkAction.INSTANCE);
8383
for (String bulkItem : bulkData) {
8484
builder.add(new IndexRequest(indexName, typeName).source(bulkItem.getBytes(StandardCharsets.UTF_8), XContentType.JSON));
8585
}
@@ -108,7 +108,7 @@ private TransportSearchRequestExecutor(TransportClient client, String indexName)
108108
@Override
109109
public boolean search(String source) {
110110
final SearchResponse response;
111-
NoopSearchRequestBuilder builder = NoopSearchAction.INSTANCE.newRequestBuilder(client);
111+
NoopSearchRequestBuilder builder = new NoopSearchRequestBuilder(client, NoopSearchAction.INSTANCE);
112112
try {
113113
builder.setIndices(indexName);
114114
builder.setQuery(QueryBuilders.wrapperQuery(source));

client/client-benchmark-noop-api-plugin/src/main/java/org/elasticsearch/plugin/noop/action/bulk/NoopBulkAction.java

+1-7
Original file line numberDiff line numberDiff line change
@@ -21,9 +21,8 @@
2121
import org.elasticsearch.action.Action;
2222
import org.elasticsearch.action.bulk.BulkRequest;
2323
import org.elasticsearch.action.bulk.BulkResponse;
24-
import org.elasticsearch.client.ElasticsearchClient;
2524

26-
public class NoopBulkAction extends Action<BulkRequest, BulkResponse, NoopBulkRequestBuilder> {
25+
public class NoopBulkAction extends Action<BulkRequest, BulkResponse> {
2726
public static final String NAME = "mock:data/write/bulk";
2827

2928
public static final NoopBulkAction INSTANCE = new NoopBulkAction();
@@ -32,11 +31,6 @@ private NoopBulkAction() {
3231
super(NAME);
3332
}
3433

35-
@Override
36-
public NoopBulkRequestBuilder newRequestBuilder(ElasticsearchClient client) {
37-
return new NoopBulkRequestBuilder(client, this);
38-
}
39-
4034
@Override
4135
public BulkResponse newResponse() {
4236
return new BulkResponse(null, 0);

client/client-benchmark-noop-api-plugin/src/main/java/org/elasticsearch/plugin/noop/action/bulk/NoopBulkRequestBuilder.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -35,7 +35,7 @@
3535
import org.elasticsearch.common.unit.TimeValue;
3636
import org.elasticsearch.common.xcontent.XContentType;
3737

38-
public class NoopBulkRequestBuilder extends ActionRequestBuilder<BulkRequest, BulkResponse, NoopBulkRequestBuilder>
38+
public class NoopBulkRequestBuilder extends ActionRequestBuilder<BulkRequest, BulkResponse>
3939
implements WriteRequestBuilder<NoopBulkRequestBuilder> {
4040

4141
public NoopBulkRequestBuilder(ElasticsearchClient client, NoopBulkAction action) {

client/client-benchmark-noop-api-plugin/src/main/java/org/elasticsearch/plugin/noop/action/search/NoopSearchAction.java

+1-7
Original file line numberDiff line numberDiff line change
@@ -21,21 +21,15 @@
2121
import org.elasticsearch.action.Action;
2222
import org.elasticsearch.action.search.SearchRequest;
2323
import org.elasticsearch.action.search.SearchResponse;
24-
import org.elasticsearch.client.ElasticsearchClient;
2524

26-
public class NoopSearchAction extends Action<SearchRequest, SearchResponse, NoopSearchRequestBuilder> {
25+
public class NoopSearchAction extends Action<SearchRequest, SearchResponse> {
2726
public static final NoopSearchAction INSTANCE = new NoopSearchAction();
2827
public static final String NAME = "mock:data/read/search";
2928

3029
public NoopSearchAction() {
3130
super(NAME);
3231
}
3332

34-
@Override
35-
public NoopSearchRequestBuilder newRequestBuilder(ElasticsearchClient client) {
36-
return new NoopSearchRequestBuilder(client, this);
37-
}
38-
3933
@Override
4034
public SearchResponse newResponse() {
4135
return new SearchResponse();

client/client-benchmark-noop-api-plugin/src/main/java/org/elasticsearch/plugin/noop/action/search/NoopSearchRequestBuilder.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -42,7 +42,7 @@
4242
import java.util.Arrays;
4343
import java.util.List;
4444

45-
public class NoopSearchRequestBuilder extends ActionRequestBuilder<SearchRequest, SearchResponse, NoopSearchRequestBuilder> {
45+
public class NoopSearchRequestBuilder extends ActionRequestBuilder<SearchRequest, SearchResponse> {
4646

4747
public NoopSearchRequestBuilder(ElasticsearchClient client, NoopSearchAction action) {
4848
super(client, action, new SearchRequest());

modules/ingest-common/src/main/java/org/elasticsearch/ingest/common/GrokProcessorGetAction.java

+2-8
Original file line numberDiff line numberDiff line change
@@ -52,8 +52,7 @@
5252
import static org.elasticsearch.rest.RestRequest.Method.GET;
5353
import static org.elasticsearch.rest.RestStatus.OK;
5454

55-
public class GrokProcessorGetAction extends Action<GrokProcessorGetAction.Request,
56-
GrokProcessorGetAction.Response, GrokProcessorGetAction.RequestBuilder> {
55+
public class GrokProcessorGetAction extends Action<GrokProcessorGetAction.Request, GrokProcessorGetAction.Response> {
5756

5857
public static final GrokProcessorGetAction INSTANCE = new GrokProcessorGetAction();
5958
public static final String NAME = "cluster:admin/ingest/processor/grok/get";
@@ -62,11 +61,6 @@ private GrokProcessorGetAction() {
6261
super(NAME);
6362
}
6463

65-
@Override
66-
public RequestBuilder newRequestBuilder(ElasticsearchClient client) {
67-
return new RequestBuilder(client);
68-
}
69-
7064
@Override
7165
public Response newResponse() {
7266
return new Response(null);
@@ -79,7 +73,7 @@ public ActionRequestValidationException validate() {
7973
}
8074
}
8175

82-
public static class RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder> {
76+
public static class RequestBuilder extends ActionRequestBuilder<Request, Response> {
8377
public RequestBuilder(ElasticsearchClient client) {
8478
super(client, GrokProcessorGetAction.INSTANCE, new Request());
8579
}

modules/lang-mustache/src/main/java/org/elasticsearch/script/mustache/MultiSearchTemplateAction.java

+1-8
Original file line numberDiff line numberDiff line change
@@ -20,10 +20,8 @@
2020
package org.elasticsearch.script.mustache;
2121

2222
import org.elasticsearch.action.Action;
23-
import org.elasticsearch.client.ElasticsearchClient;
2423

25-
public class MultiSearchTemplateAction
26-
extends Action<MultiSearchTemplateRequest, MultiSearchTemplateResponse, MultiSearchTemplateRequestBuilder> {
24+
public class MultiSearchTemplateAction extends Action<MultiSearchTemplateRequest, MultiSearchTemplateResponse> {
2725

2826
public static final MultiSearchTemplateAction INSTANCE = new MultiSearchTemplateAction();
2927
public static final String NAME = "indices:data/read/msearch/template";
@@ -36,9 +34,4 @@ private MultiSearchTemplateAction() {
3634
public MultiSearchTemplateResponse newResponse() {
3735
return new MultiSearchTemplateResponse();
3836
}
39-
40-
@Override
41-
public MultiSearchTemplateRequestBuilder newRequestBuilder(ElasticsearchClient client) {
42-
return new MultiSearchTemplateRequestBuilder(client, this);
43-
}
4437
}

modules/lang-mustache/src/main/java/org/elasticsearch/script/mustache/MultiSearchTemplateRequestBuilder.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -24,7 +24,7 @@
2424
import org.elasticsearch.client.ElasticsearchClient;
2525

2626
public class MultiSearchTemplateRequestBuilder
27-
extends ActionRequestBuilder<MultiSearchTemplateRequest, MultiSearchTemplateResponse, MultiSearchTemplateRequestBuilder> {
27+
extends ActionRequestBuilder<MultiSearchTemplateRequest, MultiSearchTemplateResponse> {
2828

2929
protected MultiSearchTemplateRequestBuilder(ElasticsearchClient client, MultiSearchTemplateAction action) {
3030
super(client, action, new MultiSearchTemplateRequest());

modules/lang-mustache/src/main/java/org/elasticsearch/script/mustache/SearchTemplateAction.java

+1-7
Original file line numberDiff line numberDiff line change
@@ -20,9 +20,8 @@
2020
package org.elasticsearch.script.mustache;
2121

2222
import org.elasticsearch.action.Action;
23-
import org.elasticsearch.client.ElasticsearchClient;
2423

25-
public class SearchTemplateAction extends Action<SearchTemplateRequest, SearchTemplateResponse, SearchTemplateRequestBuilder> {
24+
public class SearchTemplateAction extends Action<SearchTemplateRequest, SearchTemplateResponse> {
2625

2726
public static final SearchTemplateAction INSTANCE = new SearchTemplateAction();
2827
public static final String NAME = "indices:data/read/search/template";
@@ -31,11 +30,6 @@ private SearchTemplateAction() {
3130
super(NAME);
3231
}
3332

34-
@Override
35-
public SearchTemplateRequestBuilder newRequestBuilder(ElasticsearchClient client) {
36-
return new SearchTemplateRequestBuilder(client, this);
37-
}
38-
3933
@Override
4034
public SearchTemplateResponse newResponse() {
4135
return new SearchTemplateResponse();

modules/lang-mustache/src/main/java/org/elasticsearch/script/mustache/SearchTemplateRequestBuilder.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -27,7 +27,7 @@
2727
import java.util.Map;
2828

2929
public class SearchTemplateRequestBuilder
30-
extends ActionRequestBuilder<SearchTemplateRequest, SearchTemplateResponse, SearchTemplateRequestBuilder> {
30+
extends ActionRequestBuilder<SearchTemplateRequest, SearchTemplateResponse> {
3131

3232
SearchTemplateRequestBuilder(ElasticsearchClient client, SearchTemplateAction action) {
3333
super(client, action, new SearchTemplateRequest());

modules/lang-painless/src/main/java/org/elasticsearch/painless/PainlessExecuteAction.java

+2-8
Original file line numberDiff line numberDiff line change
@@ -62,8 +62,7 @@
6262
import static org.elasticsearch.rest.RestRequest.Method.POST;
6363
import static org.elasticsearch.rest.RestStatus.OK;
6464

65-
public class PainlessExecuteAction extends Action<PainlessExecuteAction.Request, PainlessExecuteAction.Response,
66-
PainlessExecuteAction.RequestBuilder> {
65+
public class PainlessExecuteAction extends Action<PainlessExecuteAction.Request, PainlessExecuteAction.Response> {
6766

6867
static final PainlessExecuteAction INSTANCE = new PainlessExecuteAction();
6968
private static final String NAME = "cluster:admin/scripts/painless/execute";
@@ -72,11 +71,6 @@ private PainlessExecuteAction() {
7271
super(NAME);
7372
}
7473

75-
@Override
76-
public RequestBuilder newRequestBuilder(ElasticsearchClient client) {
77-
return new RequestBuilder(client);
78-
}
79-
8074
@Override
8175
public Response newResponse() {
8276
return new Response();
@@ -201,7 +195,7 @@ public static SupportedContext fromId(byte id) {
201195

202196
}
203197

204-
public static class RequestBuilder extends ActionRequestBuilder<Request, Response, RequestBuilder> {
198+
public static class RequestBuilder extends ActionRequestBuilder<Request, Response> {
205199

206200
RequestBuilder(ElasticsearchClient client) {
207201
super(client, INSTANCE, new Request());

modules/rank-eval/src/main/java/org/elasticsearch/index/rankeval/RankEvalAction.java

+1-7
Original file line numberDiff line numberDiff line change
@@ -20,12 +20,11 @@
2020
package org.elasticsearch.index.rankeval;
2121

2222
import org.elasticsearch.action.Action;
23-
import org.elasticsearch.client.ElasticsearchClient;
2423

2524
/**
2625
* Action for explaining evaluating search ranking results.
2726
*/
28-
public class RankEvalAction extends Action<RankEvalRequest, RankEvalResponse, RankEvalRequestBuilder> {
27+
public class RankEvalAction extends Action<RankEvalRequest, RankEvalResponse> {
2928

3029
public static final RankEvalAction INSTANCE = new RankEvalAction();
3130
public static final String NAME = "indices:data/read/rank_eval";
@@ -34,11 +33,6 @@ private RankEvalAction() {
3433
super(NAME);
3534
}
3635

37-
@Override
38-
public RankEvalRequestBuilder newRequestBuilder(ElasticsearchClient client) {
39-
return new RankEvalRequestBuilder(client, this, new RankEvalRequest());
40-
}
41-
4236
@Override
4337
public RankEvalResponse newResponse() {
4438
return new RankEvalResponse();

modules/rank-eval/src/main/java/org/elasticsearch/index/rankeval/RankEvalRequestBuilder.java

+2-2
Original file line numberDiff line numberDiff line change
@@ -23,9 +23,9 @@
2323
import org.elasticsearch.action.ActionRequestBuilder;
2424
import org.elasticsearch.client.ElasticsearchClient;
2525

26-
public class RankEvalRequestBuilder extends ActionRequestBuilder<RankEvalRequest, RankEvalResponse, RankEvalRequestBuilder> {
26+
public class RankEvalRequestBuilder extends ActionRequestBuilder<RankEvalRequest, RankEvalResponse> {
2727

28-
public RankEvalRequestBuilder(ElasticsearchClient client, Action<RankEvalRequest, RankEvalResponse, RankEvalRequestBuilder> action,
28+
public RankEvalRequestBuilder(ElasticsearchClient client, Action<RankEvalRequest, RankEvalResponse> action,
2929
RankEvalRequest request) {
3030
super(client, action, request);
3131
}

modules/reindex/src/main/java/org/elasticsearch/index/reindex/BulkByScrollParallelizationHelper.java

+3-3
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ private BulkByScrollParallelizationHelper() {}
6161
static <Request extends AbstractBulkByScrollRequest<Request>> void startSlicedAction(
6262
Request request,
6363
BulkByScrollTask task,
64-
Action<Request, BulkByScrollResponse, ?> action,
64+
Action<Request, BulkByScrollResponse> action,
6565
ActionListener<BulkByScrollResponse> listener,
6666
Client client,
6767
DiscoveryNode node,
@@ -85,7 +85,7 @@ static <Request extends AbstractBulkByScrollRequest<Request>> void startSlicedAc
8585
private static <Request extends AbstractBulkByScrollRequest<Request>> void sliceConditionally(
8686
Request request,
8787
BulkByScrollTask task,
88-
Action<Request, BulkByScrollResponse, ?> action,
88+
Action<Request, BulkByScrollResponse> action,
8989
ActionListener<BulkByScrollResponse> listener,
9090
Client client,
9191
DiscoveryNode node,
@@ -118,7 +118,7 @@ private static int countSlicesBasedOnShards(ClusterSearchShardsResponse response
118118

119119
private static <Request extends AbstractBulkByScrollRequest<Request>> void sendSubRequests(
120120
Client client,
121-
Action<Request, BulkByScrollResponse, ?> action,
121+
Action<Request, BulkByScrollResponse> action,
122122
String localNodeId,
123123
BulkByScrollTask task,
124124
Request request,

modules/reindex/src/main/java/org/elasticsearch/index/reindex/RethrottleAction.java

+1-7
Original file line numberDiff line numberDiff line change
@@ -21,21 +21,15 @@
2121

2222
import org.elasticsearch.action.Action;
2323
import org.elasticsearch.action.admin.cluster.node.tasks.list.ListTasksResponse;
24-
import org.elasticsearch.client.ElasticsearchClient;
2524

26-
public class RethrottleAction extends Action<RethrottleRequest, ListTasksResponse, RethrottleRequestBuilder> {
25+
public class RethrottleAction extends Action<RethrottleRequest, ListTasksResponse> {
2726
public static final RethrottleAction INSTANCE = new RethrottleAction();
2827
public static final String NAME = "cluster:admin/reindex/rethrottle";
2928

3029
private RethrottleAction() {
3130
super(NAME);
3231
}
3332

34-
@Override
35-
public RethrottleRequestBuilder newRequestBuilder(ElasticsearchClient client) {
36-
return new RethrottleRequestBuilder(client, this);
37-
}
38-
3933
@Override
4034
public ListTasksResponse newResponse() {
4135
return new ListTasksResponse();

modules/reindex/src/main/java/org/elasticsearch/index/reindex/RethrottleRequestBuilder.java

+1-1
Original file line numberDiff line numberDiff line change
@@ -29,7 +29,7 @@
2929
*/
3030
public class RethrottleRequestBuilder extends TasksRequestBuilder<RethrottleRequest, ListTasksResponse, RethrottleRequestBuilder> {
3131
public RethrottleRequestBuilder(ElasticsearchClient client,
32-
Action<RethrottleRequest, ListTasksResponse, RethrottleRequestBuilder> action) {
32+
Action<RethrottleRequest, ListTasksResponse> action) {
3333
super(client, action, new RethrottleRequest());
3434
}
3535

0 commit comments

Comments
 (0)