Github user wuchong commented on the issue:
https://github.com/apache/flink/pull/3269
Hi @tonycox , thanks for this PR.
It seems that you are using column names to represent the (nested) fields
that are projected. I'm afraid that it can't work when the composite columns
have the same nested field name. Such as a table schema `student<name, age>,
teacher<name, age>`, and the projected fields are `name, age`, we can't
determine whether the `name` is `student.name` or `teacher.name`.
IMO, we can use the full qualifier column names with `.` separator to
represent the (nested) fields. For the above example, the projected fields
could be `student.name, teacher.age`. And then we can use it to do nested field
projection push down.
What do you think ?
Thanks,
Jark Wu
---
If your project is set up for it, you can reply to this email and have your
reply appear on GitHub as well. If your project does not have this feature
enabled and wishes so, or if the feature is enabled but not working, please
contact infrastructure at infrastruct...@apache.org or file a JIRA ticket
with INFRA.
---
