[
https://issues.apache.org/jira/browse/FLINK-21520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17300105#comment-17300105
]
Danny Chen commented on FLINK-21520:
------------------------------------
I'm working on Flink on Apache HUDI now, and we use the Flink parquet format,
in order to make time travel query, we need the filter expression push down for
the Parquet format, which is ignored in current code base.
I'm glad that you need this feature too, can you contribute for the code ? I
can help for the code review ~
> ParquetInputFormat#setfilterPredicate() does not work
> -----------------------------------------------------
>
> Key: FLINK-21520
> URL: https://issues.apache.org/jira/browse/FLINK-21520
> Project: Flink
> Issue Type: Bug
> Reporter: Etienne Chauchot
> Priority: Major
>
> Simplified code:
> {code:java}
> FilterPredicate filterPredicate = eq(intColumn("intField"), 10);
> parquetInputFormat.setFilterPredicate(filterPredicate);
> env.createInput(parquetInputFormat);
> {code}
>
> produces no records whereas
> {code:java}
> env.createInput(parquetInputFormat)
> .filter((FilterFunction) value -> value.get("intField") == 10);
> {code}
> produces records.
--
This message was sent by Atlassian Jira
(v8.3.4#803005)
