Skip to content

Commit fc4edd8

Browse files
Prepare for backport to 9.1 and 8.19
1 parent 80cbc9f commit fc4edd8

File tree

4 files changed

+25
-3
lines changed

4 files changed

+25
-3
lines changed

server/src/main/java/org/elasticsearch/TransportVersions.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -211,6 +211,7 @@ static TransportVersion def(int id) {
211211
public static final TransportVersion ESQL_DOCUMENTS_FOUND_AND_VALUES_LOADED_8_19 = def(8_841_0_61);
212212
public static final TransportVersion ESQL_PROFILE_INCLUDE_PLAN_8_19 = def(8_841_0_62);
213213
public static final TransportVersion ESQL_SPLIT_ON_BIG_VALUES_8_19 = def(8_841_0_63);
214+
public static final TransportVersion ESQL_FIXED_INDEX_LIKE_8_19 = def(8_841_0_64);
214215
public static final TransportVersion V_9_0_0 = def(9_000_0_09);
215216
public static final TransportVersion INITIAL_ELASTICSEARCH_9_0_1 = def(9_000_0_10);
216217
public static final TransportVersion INITIAL_ELASTICSEARCH_9_0_2 = def(9_000_0_11);
@@ -328,6 +329,7 @@ static TransportVersion def(int id) {
328329
public static final TransportVersion ESQL_PROFILE_INCLUDE_PLAN = def(9_111_0_00);
329330
public static final TransportVersion MAPPINGS_IN_DATA_STREAMS = def(9_112_0_00);
330331
public static final TransportVersion ESQL_SPLIT_ON_BIG_VALUES_9_1 = def(9_112_0_01);
332+
public static final TransportVersion ESQL_FIXED_INDEX_LIKE_9_1 = def(9_112_0_02);
331333
public static final TransportVersion ESQL_FIXED_INDEX_LIKE = def(9_119_0_00);
332334

333335
/*

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

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,9 @@
3131
import java.io.IOException;
3232
import java.util.Objects;
3333

34+
import static org.elasticsearch.TransportVersions.ESQL_FIXED_INDEX_LIKE_8_19;
35+
import static org.elasticsearch.TransportVersions.ESQL_FIXED_INDEX_LIKE_9_1;
36+
3437
/**
3538
* Implements the wildcard search query. Supported wildcards are {@code *}, which
3639
* matches any character sequence (including the empty one), and {@code ?},
@@ -104,7 +107,9 @@ public WildcardQueryBuilder(StreamInput in) throws IOException {
104107
value = in.readString();
105108
rewrite = in.readOptionalString();
106109
caseInsensitive = in.readBoolean();
107-
if (in.getTransportVersion().onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)) {
110+
if (in.getTransportVersion().onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)
111+
|| in.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_8_19)
112+
|| in.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_9_1)) {
108113
forceStringMatch = in.readBoolean();
109114
} else {
110115
forceStringMatch = false;
@@ -117,7 +122,9 @@ protected void doWriteTo(StreamOutput out) throws IOException {
117122
out.writeString(value);
118123
out.writeOptionalString(rewrite);
119124
out.writeBoolean(caseInsensitive);
120-
if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)) {
125+
if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)
126+
|| out.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_8_19)
127+
|| out.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_9_1)) {
121128
out.writeBoolean(forceStringMatch);
122129
}
123130
}

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/expression/function/scalar/string/regex/WildcardLikeList.java

Lines changed: 7 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -35,6 +35,9 @@
3535
import java.util.function.Supplier;
3636
import java.util.stream.Collectors;
3737

38+
import static org.elasticsearch.TransportVersions.ESQL_FIXED_INDEX_LIKE_8_19;
39+
import static org.elasticsearch.TransportVersions.ESQL_FIXED_INDEX_LIKE_9_1;
40+
3841
public class WildcardLikeList extends RegexMatch<WildcardPatternList> {
3942
public static final NamedWriteableRegistry.Entry ENTRY = new NamedWriteableRegistry.Entry(
4043
Expression.class,
@@ -145,7 +148,10 @@ public Query asQuery(LucenePushdownPredicates pushdownPredicates, TranslatorHand
145148
}
146149

147150
private boolean supportsPushdown(TransportVersion version) {
148-
return version == null || version.onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE);
151+
return version == null
152+
|| version.onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)
153+
|| version.isPatchFrom(ESQL_FIXED_INDEX_LIKE_8_19)
154+
|| version.isPatchFrom(ESQL_FIXED_INDEX_LIKE_9_1);
149155
}
150156

151157
@Override

x-pack/plugin/esql/src/main/java/org/elasticsearch/xpack/esql/io/stream/PlanStreamWrapperQueryBuilder.java

Lines changed: 7 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -56,6 +56,13 @@ public TransportVersion getMinimalSupportedVersion() {
5656
return TransportVersions.ESQL_FIXED_INDEX_LIKE;
5757
}
5858

59+
@Override
60+
public boolean supportsVersion(TransportVersion version) {
61+
return version.onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)
62+
|| version.isPatchFrom(TransportVersions.ESQL_FIXED_INDEX_LIKE_8_19)
63+
|| version.isPatchFrom(TransportVersions.ESQL_FIXED_INDEX_LIKE_9_1);
64+
}
65+
5966
@Override
6067
public Query toQuery(SearchExecutionContext context) throws IOException {
6168
return next.toQuery(context);

0 commit comments

Comments
 (0)