Skip to content

Commit 0b945d4

Browse files
committed
Make ccsMinimizeRoundtrips nullable
1 parent 071f6c5 commit 0b945d4

File tree

7 files changed

+13
-13
lines changed

7 files changed

+13
-13
lines changed

server/src/main/java/org/elasticsearch/action/admin/indices/validate/query/TransportValidateQueryAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -130,7 +130,7 @@ protected void doExecute(Task task, ValidateQueryRequest request, ActionListener
130130
} else {
131131
Rewriteable.rewriteAndFetch(
132132
request.query(),
133-
searchService.getRewriteContext(timeProvider, resolvedIndices, null, true),
133+
searchService.getRewriteContext(timeProvider, resolvedIndices, null, null),
134134
rewriteListener
135135
);
136136
}

server/src/main/java/org/elasticsearch/action/explain/TransportExplainAction.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -105,7 +105,7 @@ protected void doExecute(Task task, ExplainRequest request, ActionListener<Expla
105105
LongSupplier timeProvider = () -> request.nowInMillis;
106106
Rewriteable.rewriteAndFetch(
107107
request.query(),
108-
searchService.getRewriteContext(timeProvider, resolvedIndices, null, true),
108+
searchService.getRewriteContext(timeProvider, resolvedIndices, null, null),
109109
rewriteListener
110110
);
111111
}

server/src/main/java/org/elasticsearch/index/query/QueryRewriteContext.java

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -72,7 +72,7 @@ public class QueryRewriteContext {
7272
private final ResolvedIndices resolvedIndices;
7373
private final PointInTimeBuilder pit;
7474
private QueryRewriteInterceptor queryRewriteInterceptor;
75-
private final boolean ccsMinimizeRoundtrips;
75+
private final Boolean ccsMinimizeRoundtrips;
7676
private final boolean isExplain;
7777

7878
public QueryRewriteContext(
@@ -92,7 +92,7 @@ public QueryRewriteContext(
9292
final ResolvedIndices resolvedIndices,
9393
final PointInTimeBuilder pit,
9494
final QueryRewriteInterceptor queryRewriteInterceptor,
95-
final boolean ccsMinimizeRoundtrips,
95+
final Boolean ccsMinimizeRoundtrips,
9696
final boolean isExplain
9797
) {
9898

@@ -135,7 +135,7 @@ public QueryRewriteContext(final XContentParserConfiguration parserConfiguration
135135
null,
136136
null,
137137
null,
138-
true,
138+
null,
139139
false
140140
);
141141
}
@@ -147,7 +147,7 @@ public QueryRewriteContext(
147147
final ResolvedIndices resolvedIndices,
148148
final PointInTimeBuilder pit,
149149
final QueryRewriteInterceptor queryRewriteInterceptor,
150-
final boolean ccsMinimizeRoundtrips
150+
final Boolean ccsMinimizeRoundtrips
151151
) {
152152
this(parserConfiguration, client, nowInMillis, resolvedIndices, pit, queryRewriteInterceptor, ccsMinimizeRoundtrips, false);
153153
}
@@ -159,7 +159,7 @@ public QueryRewriteContext(
159159
final ResolvedIndices resolvedIndices,
160160
final PointInTimeBuilder pit,
161161
final QueryRewriteInterceptor queryRewriteInterceptor,
162-
final boolean ccsMinimizeRoundtrips,
162+
final Boolean ccsMinimizeRoundtrips,
163163
final boolean isExplain
164164
) {
165165
this(
@@ -286,7 +286,7 @@ public void setMapUnmappedFieldAsString(boolean mapUnmappedFieldAsString) {
286286
this.mapUnmappedFieldAsString = mapUnmappedFieldAsString;
287287
}
288288

289-
public boolean isCcsMinimizeRoundtrips() {
289+
public Boolean isCcsMinimizeRoundtrips() {
290290
return ccsMinimizeRoundtrips;
291291
}
292292

server/src/main/java/org/elasticsearch/indices/IndicesService.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1849,7 +1849,7 @@ public QueryRewriteContext getRewriteContext(
18491849
LongSupplier nowInMillis,
18501850
ResolvedIndices resolvedIndices,
18511851
PointInTimeBuilder pit,
1852-
final boolean ccsMinimizeRoundtrips,
1852+
final Boolean ccsMinimizeRoundtrips,
18531853
final boolean isExplain
18541854
) {
18551855
return new QueryRewriteContext(

server/src/main/java/org/elasticsearch/search/SearchService.java

Lines changed: 2 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -2131,7 +2131,7 @@ public QueryRewriteContext getRewriteContext(
21312131
LongSupplier nowInMillis,
21322132
ResolvedIndices resolvedIndices,
21332133
PointInTimeBuilder pit,
2134-
final boolean ccsMinimizeRoundtrips
2134+
final Boolean ccsMinimizeRoundtrips
21352135
) {
21362136
return getRewriteContext(nowInMillis, resolvedIndices, pit, ccsMinimizeRoundtrips, false);
21372137
}
@@ -2143,7 +2143,7 @@ public QueryRewriteContext getRewriteContext(
21432143
LongSupplier nowInMillis,
21442144
ResolvedIndices resolvedIndices,
21452145
PointInTimeBuilder pit,
2146-
final boolean ccsMinimizeRoundtrips,
2146+
final Boolean ccsMinimizeRoundtrips,
21472147
final boolean isExplain
21482148
) {
21492149
return indicesService.getRewriteContext(nowInMillis, resolvedIndices, pit, ccsMinimizeRoundtrips, isExplain);

server/src/test/java/org/elasticsearch/action/search/TransportSearchActionTests.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1785,7 +1785,7 @@ protected void doWriteTo(StreamOutput out) throws IOException {
17851785

17861786
SearchService searchService = mock(SearchService.class);
17871787
when(searchService.getRewriteContext(any(), any(), any(), anyBoolean(), anyBoolean())).thenReturn(
1788-
new QueryRewriteContext(null, null, null, null, null, null, true)
1788+
new QueryRewriteContext(null, null, null, null, null, null, null)
17891789
);
17901790
ClusterService clusterService = new ClusterService(
17911791
settings,

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/expression/function/fulltext/QueryBuilderResolver.java

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,7 @@ private static QueryRewriteContext queryRewriteContext(TransportActionServices s
6161
System.currentTimeMillis()
6262
);
6363

64-
return services.searchService().getRewriteContext(System::currentTimeMillis, resolvedIndices, null, true);
64+
return services.searchService().getRewriteContext(System::currentTimeMillis, resolvedIndices, null, null);
6565
}
6666

6767
private static Set<String> indexNames(LogicalPlan plan) {

0 commit comments

Comments
 (0)