|
21 | 21 | import org.elasticsearch.xpack.esql.EsqlTestUtils; |
22 | 22 | import org.elasticsearch.xpack.esql.TestBlockFactory; |
23 | 23 | import org.elasticsearch.xpack.esql.VerificationException; |
| 24 | +import org.elasticsearch.xpack.esql.action.EsqlCapabilities; |
24 | 25 | import org.elasticsearch.xpack.esql.analysis.Analyzer; |
25 | 26 | import org.elasticsearch.xpack.esql.analysis.AnalyzerContext; |
26 | 27 | import org.elasticsearch.xpack.esql.analysis.AnalyzerTestUtils; |
@@ -4910,6 +4911,8 @@ public void testPlanSanityCheck() throws Exception { |
4910 | 4911 | } |
4911 | 4912 |
|
4912 | 4913 | public void testPlanSanityCheckWithBinaryPlans() throws Exception { |
| 4914 | + assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V5.isEnabled()); |
| 4915 | + |
4913 | 4916 | var plan = optimizedPlan(""" |
4914 | 4917 | FROM test |
4915 | 4918 | | RENAME languages AS language_code |
@@ -5913,6 +5916,8 @@ public void testLookupStats() { |
5913 | 5916 | * \_EsRelation[language_code][LOOKUP][language_code{f}#18, language_name{f}#19] |
5914 | 5917 | */ |
5915 | 5918 | public void testLookupJoinPushDownFilterOnJoinKeyWithRename() { |
| 5919 | + assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V5.isEnabled()); |
| 5920 | + |
5916 | 5921 | String query = """ |
5917 | 5922 | FROM test |
5918 | 5923 | | RENAME languages AS language_code |
@@ -5954,6 +5959,8 @@ public void testLookupJoinPushDownFilterOnJoinKeyWithRename() { |
5954 | 5959 | * \_EsRelation[language_code][LOOKUP][language_code{f}#18, language_name{f}#19] |
5955 | 5960 | */ |
5956 | 5961 | public void testLookupJoinPushDownFilterOnLeftSideField() { |
| 5962 | + assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V5.isEnabled()); |
| 5963 | + |
5957 | 5964 | String query = """ |
5958 | 5965 | FROM test |
5959 | 5966 | | RENAME languages AS language_code |
@@ -5996,6 +6003,8 @@ public void testLookupJoinPushDownFilterOnLeftSideField() { |
5996 | 6003 | * \_EsRelation[language_code][LOOKUP][language_code{f}#18, language_name{f}#19] |
5997 | 6004 | */ |
5998 | 6005 | public void testLookupJoinPushDownDisabledForLookupField() { |
| 6006 | + assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V5.isEnabled()); |
| 6007 | + |
5999 | 6008 | String query = """ |
6000 | 6009 | FROM test |
6001 | 6010 | | RENAME languages AS language_code |
@@ -6039,6 +6048,8 @@ public void testLookupJoinPushDownDisabledForLookupField() { |
6039 | 6048 | * \_EsRelation[language_code][LOOKUP][language_code{f}#19, language_name{f}#20] |
6040 | 6049 | */ |
6041 | 6050 | public void testLookupJoinPushDownSeparatedForConjunctionBetweenLeftAndRightField() { |
| 6051 | + assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V5.isEnabled()); |
| 6052 | + |
6042 | 6053 | String query = """ |
6043 | 6054 | FROM test |
6044 | 6055 | | RENAME languages AS language_code |
@@ -6090,6 +6101,8 @@ public void testLookupJoinPushDownSeparatedForConjunctionBetweenLeftAndRightFiel |
6090 | 6101 | * \_EsRelation[language_code][LOOKUP][language_code{f}#19, language_name{f}#20] |
6091 | 6102 | */ |
6092 | 6103 | public void testLookupJoinPushDownDisabledForDisjunctionBetweenLeftAndRightField() { |
| 6104 | + assumeTrue("Requires LOOKUP JOIN", EsqlCapabilities.Cap.JOIN_LOOKUP_V5.isEnabled()); |
| 6105 | + |
6093 | 6106 | String query = """ |
6094 | 6107 | FROM test |
6095 | 6108 | | RENAME languages AS language_code |
|
0 commit comments