@@ -223,6 +223,15 @@ public void testPredicatePushdown()
223
223
.returnsEmptyResult ()
224
224
.isFullyPushedDown ();
225
225
226
+ // varchar predicate over join
227
+ Session joinPushdownEnabled = joinPushdownEnabled (getSession ());
228
+ assertThat (query (joinPushdownEnabled , "SELECT c.name, n.name FROM customer c JOIN nation n ON c.custkey = n.nationkey WHERE n.name = 'POLAND'" ))
229
+ .isFullyPushedDown ();
230
+
231
+ // join on varchar columns
232
+ assertThat (query (joinPushdownEnabled , "SELECT n.name, n2.regionkey FROM nation n JOIN nation n2 ON n.name = n2.name" ))
233
+ .isFullyPushedDown ();
234
+
226
235
// bigint equality
227
236
assertThat (query ("SELECT regionkey, nationkey, name FROM nation WHERE nationkey = 19" ))
228
237
.matches ("VALUES (BIGINT '3', BIGINT '19', CAST('ROMANIA' AS varchar(25)))" )
@@ -286,15 +295,6 @@ public void testPredicatePushdown()
286
295
assertThat (query ("SELECT * FROM " + testTable .getName () + " WHERE long_decimal = 123456789.987654321" ))
287
296
.matches ("VALUES (CAST(123.321 AS decimal(9,3)), CAST(123456789.987654321 AS decimal(30, 10)))" )
288
297
.isFullyPushedDown ();
289
-
290
- // varchar predicate over join
291
- Session joinPushdownEnabled = joinPushdownEnabled (getSession ());
292
- assertThat (query (joinPushdownEnabled , "SELECT c.name, n.name FROM customer c JOIN nation n ON c.custkey = n.nationkey WHERE n.name = 'POLAND'" ))
293
- .isFullyPushedDown ();
294
-
295
- // join on varchar columns
296
- assertThat (query (joinPushdownEnabled , "SELECT n.name, n2.regionkey FROM nation n JOIN nation n2 ON n.name = n2.name" ))
297
- .isFullyPushedDown ();
298
298
}
299
299
}
300
300
0 commit comments