Skip to content

Commit 6831656

Browse files
Address code review feedback
1 parent d96a8ae commit 6831656

File tree

3 files changed

+16
-19
lines changed

3 files changed

+16
-19
lines changed

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

Lines changed: 11 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -31,9 +31,6 @@
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-
3734
/**
3835
* Implements the wildcard search query. Supported wildcards are {@code *}, which
3936
* matches any character sequence (including the empty one), and {@code ?},
@@ -109,9 +106,7 @@ public WildcardQueryBuilder(StreamInput in) throws IOException {
109106
if (in.getTransportVersion().onOrAfter(TransportVersions.V_7_10_0)) {
110107
caseInsensitive = in.readBoolean();
111108
}
112-
if (in.getTransportVersion().onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)
113-
|| in.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_8_19)
114-
|| in.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_9_1)) {
109+
if (expressionTransportSupported(in.getTransportVersion())) {
115110
forceStringMatch = in.readBoolean();
116111
} else {
117112
forceStringMatch = false;
@@ -126,13 +121,20 @@ protected void doWriteTo(StreamOutput out) throws IOException {
126121
if (out.getTransportVersion().onOrAfter(TransportVersions.V_7_10_0)) {
127122
out.writeBoolean(caseInsensitive);
128123
}
129-
if (out.getTransportVersion().onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)
130-
|| out.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_8_19)
131-
|| out.getTransportVersion().isPatchFrom(ESQL_FIXED_INDEX_LIKE_9_1)) {
124+
if (expressionTransportSupported(out.getTransportVersion())) {
132125
out.writeBoolean(forceStringMatch);
133126
}
134127
}
135128

129+
/**
130+
* Returns true if the Transport version is compatible with ESQL_FIXED_INDEX_LIKE
131+
*/
132+
public static boolean expressionTransportSupported(TransportVersion version) {
133+
return version.onOrAfter(TransportVersions.ESQL_FIXED_INDEX_LIKE)
134+
|| version.isPatchFrom(TransportVersions.ESQL_FIXED_INDEX_LIKE_8_19)
135+
|| version.isPatchFrom(TransportVersions.ESQL_FIXED_INDEX_LIKE_9_1);
136+
}
137+
136138
@Override
137139
public String fieldName() {
138140
return fieldName;

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

Lines changed: 2 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -11,7 +11,6 @@
1111
import org.apache.lucene.util.automaton.Automaton;
1212
import org.apache.lucene.util.automaton.CharacterRunAutomaton;
1313
import org.elasticsearch.TransportVersion;
14-
import org.elasticsearch.TransportVersions;
1514
import org.elasticsearch.common.io.stream.NamedWriteableRegistry;
1615
import org.elasticsearch.common.io.stream.StreamInput;
1716
import org.elasticsearch.common.io.stream.StreamOutput;
@@ -35,8 +34,7 @@
3534
import java.util.function.Supplier;
3635
import java.util.stream.Collectors;
3736

38-
import static org.elasticsearch.TransportVersions.ESQL_FIXED_INDEX_LIKE_8_19;
39-
import static org.elasticsearch.TransportVersions.ESQL_FIXED_INDEX_LIKE_9_1;
37+
import static org.elasticsearch.index.query.WildcardQueryBuilder.expressionTransportSupported;
4038

4139
public class WildcardLikeList extends RegexMatch<WildcardPatternList> {
4240
public static final NamedWriteableRegistry.Entry ENTRY = new NamedWriteableRegistry.Entry(
@@ -148,10 +146,7 @@ public Query asQuery(LucenePushdownPredicates pushdownPredicates, TranslatorHand
148146
}
149147

150148
private boolean supportsPushdown(TransportVersion version) {
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);
149+
return version == null || expressionTransportSupported(version);
155150
}
156151

157152
@Override

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

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -20,6 +20,8 @@
2020

2121
import java.io.IOException;
2222

23+
import static org.elasticsearch.index.query.WildcardQueryBuilder.expressionTransportSupported;
24+
2325
/**
2426
* A {@link QueryBuilder} that wraps another {@linkplain QueryBuilder}
2527
* so it read with a {@link PlanStreamInput}.
@@ -58,9 +60,7 @@ public TransportVersion getMinimalSupportedVersion() {
5860

5961
@Override
6062
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);
63+
return expressionTransportSupported(version);
6464
}
6565

6666
@Override

0 commit comments

Comments
 (0)