You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@flink.apache.org by "xingyuan cheng (Jira)" <ji...@apache.org> on 2022/06/18 10:13:00 UTC
[jira] [Comment Edited] (FLINK-28110) Table Store Hive Reader supports projection pushdown
[ https://issues.apache.org/jira/browse/FLINK-28110?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17555878#comment-17555878 ]
xingyuan cheng edited comment on FLINK-28110 at 6/18/22 10:12 AM:
------------------------------------------------------------------
Maybe we need to use FilterUtils.isRetainedAfterApplyingFilterPredicates to filter out the expressions of type List<ResolvedExpression> from the BinaryRowData data of DataFileReader filterPredicates;
As [[TestValuesTableFactory|https://github.com/apache/flink/blob/master/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory]|[https://github.com/apache/flink/blob/master/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory]] inner class TestValuesScanTableSourceWithoutProjectionPushDown
was (Author: complone):
Maybe we need to use FilterUtils.isRetainedAfterApplyingFilterPredicates to filter out the expressions of type List<ResolvedExpression> from the BinaryRowData data of DataFileReader filterPredicates;
As [TestValuesTableFactory](https://github.com/apache/flink/blob/master/flink-table/flink-table-planner/src/test/java/org/apache/flink/table/planner/factories/TestValuesTableFactory .java) inner class TestValuesScanTableSourceWithoutProjectionPushDown
> Table Store Hive Reader supports projection pushdown
> ----------------------------------------------------
>
> Key: FLINK-28110
> URL: https://issues.apache.org/jira/browse/FLINK-28110
> Project: Flink
> Issue Type: Sub-task
> Components: Table Store
> Reporter: Jingsong Lee
> Priority: Major
> Fix For: table-store-0.2.0
>
>
> When the user declares fields in the DDL, we may not report an error when the declared fields are incomplete, at this time we can assume that the user only wants to read these fields, in fact, it is projection pushdown
--
This message was sent by Atlassian Jira
(v8.20.7#820007)