|
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