ES|QL: Lookup Join on General Filter POC

server/src/main/resources/transport/definitions/referable/esql_lookup_join_general_expression.csv

@@ -0,0 +1 @@
+9229000

server/src/main/resources/transport/upper_bounds/9.3.csv

@@ -1 +1 @@
-esql_timestamps_info,9228000
+esql_lookup_join_general_expression,9229000

x-pack/plugin/esql/qa/testFixtures/src/main/java/org/elasticsearch/xpack/esql/CsvTestsDataLoader.java

@@ -447,7 +447,7 @@ public static void loadDataSetIntoEs(
         );
     }
 
-    private static void loadDataSetIntoEs(
+    public static void loadDataSetIntoEs(
         RestClient client,
         boolean supportsIndexModeLookup,
         boolean supportsSourceFieldMapping,
@@ -698,7 +698,7 @@ record ColumnHeader(String name, String type) {}
      *   - multi-values are comma separated
      *   - commas inside multivalue fields can be escaped with \ (backslash) character
      */
-    private static void loadCsvData(RestClient client, String indexName, URL resource, boolean allowSubFields, Logger logger)
+    public static void loadCsvData(RestClient client, String indexName, URL resource, boolean allowSubFields, Logger logger)
         throws IOException {
 
         ArrayList<String> failures = new ArrayList<>();
@@ -1031,7 +1031,7 @@ private Settings readSettingsFile() throws IOException {
 
     public record EnrichConfig(String policyName, String policyFileName) {}
 
-    private interface IndexCreator {
+    public interface IndexCreator {
         void createIndex(RestClient client, String indexName, String mapping, Settings indexSettings) throws IOException;
     }
 }

x-pack/plugin/esql/qa/testFixtures/src/main/java/org/elasticsearch/xpack/esql/analysis/MutableAnalyzerContext.java

@@ -52,7 +52,14 @@ public TransportVersion minimumVersion() {
     public RestoreTransportVersion setTemporaryTransportVersionOnOrAfter(TransportVersion minVersion) {
         TransportVersion oldVersion = this.currentVersion;
         // Set to a random version between minVersion and current
-        this.currentVersion = TransportVersionUtils.randomVersionBetween(ESTestCase.random(), minVersion, TransportVersion.current());
+        // have 50+% probability of being the current version, to improve probability of catching a change
+        // that only affects the version we are trying to check in
+        boolean useCurrent = ESTestCase.randomBoolean();
+        if (useCurrent) {
+            this.currentVersion = TransportVersion.current();
+        } else {
+            this.currentVersion = TransportVersionUtils.randomVersionBetween(ESTestCase.random(), minVersion, TransportVersion.current());
+        }
         return new RestoreTransportVersion(oldVersion);
     }