[jira] [Commented] (FLINK-21520) ParquetInputFormat#setfilterPredicate() does not work

[Danny Chen (Jira)]

    [ 
https://issues.apache.org/jira/browse/FLINK-21520?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=17301550#comment-17301550
 ] 

Danny Chen commented on FLINK-21520:
------------------------------------

Thanks, i guess in your query, CPU filtering is not the resource consuming 
bottleneck.

> 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)