venkata91 commented on code in PR #23313:
URL: https://github.com/apache/flink/pull/23313#discussion_r1324865286
##########
flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/plan/rules/logical/PushFilterIntoTableSourceScanRuleTest.java:
##########
@@ -118,4 +151,34 @@ public void testWithInterval() {
util.tableEnv().executeSql(ddl);
super.testWithInterval();
}
+
+ @Test
+ public void testBasicNestedFilter() {
+ util.verifyRelPlan("SELECT * FROM NestedTable WHERE
deepNested.nested1.`value` > 2");
+ }
+
+ @Test
+ public void testNestedFilterWithDotInTheName() {
+ util.verifyRelPlan(
+ "SELECT id FROM NestedTable WHERE
`deepNestedWith.`.nested.`.value` > 5");
+ }
+
+ @Test
+ public void testNestedFilterWithBacktickInTheName() {
+ util.verifyRelPlan(
+ "SELECT id FROM NestedTable WHERE
`deepNestedWith.`.nested.```name` = 'foo'");
Review Comment:
This tests the case where the column name has backtick (`) in it and should
be escaped as the whole nested field expression name itself has to be wrapped
inside backticks. File formats like ORC etc requires the entire nested field to
be with in backticks (`)
--
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
To unsubscribe, e-mail: [email protected]
For queries about this service, please contact Infrastructure at:
[email protected]
