Skip to content

Commit 7e8e30f

Browse files
Update transport version
1 parent 2794828 commit 7e8e30f

File tree

3 files changed

+14
-1
lines changed

3 files changed

+14
-1
lines changed

server/src/main/java/org/elasticsearch/action/search/SearchRequest.java

Lines changed: 12 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -116,8 +116,12 @@ public class SearchRequest extends LegacyActionRequest implements IndicesRequest
116116
* enabling synthetic source natively in the index.
117117
*/
118118
private boolean forceSyntheticSource = false;
119+
120+
@Nullable
119121
private String projectRouting;
120122

123+
private static final TransportVersion SEARCH_PROJECT_ROUTING = TransportVersion.fromName("search_project_routing");
124+
121125
public SearchRequest() {
122126
this.localClusterAlias = null;
123127
this.absoluteStartMillis = DEFAULT_ABSOLUTE_START_MILLIS;
@@ -293,6 +297,11 @@ public SearchRequest(StreamInput in) throws IOException {
293297
} else {
294298
forceSyntheticSource = false;
295299
}
300+
if (in.getTransportVersion().supports(SEARCH_PROJECT_ROUTING)) {
301+
this.projectRouting = in.readOptionalString();
302+
} else {
303+
this.projectRouting = null;
304+
}
296305
}
297306

298307
@Override
@@ -339,6 +348,9 @@ public void writeTo(StreamOutput out, boolean skipIndices) throws IOException {
339348
throw new IllegalArgumentException("force_synthetic_source is not supported before 8.4.0");
340349
}
341350
}
351+
if (out.getTransportVersion().supports(SEARCH_PROJECT_ROUTING)) {
352+
out.writeOptionalString(this.projectRouting);
353+
}
342354
}
343355

344356
@Override
Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1 @@
1+
9218000
Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
resharding_shard_summary_in_esql,9217000
1+
search_project_routing,9218000

0 commit comments

Comments
 (0)