You are viewing a plain text version of this content. The canonical link for it is here.

Posted to issues@flink.apache.org by "Etienne Chauchot (Jira)" <ji...@apache.org> on 2021/02/26 14:27:00 UTC

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

     [ https://issues.apache.org/jira/browse/FLINK-21520?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Etienne Chauchot updated FLINK-21520:
-------------------------------------
    Description: 
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.


  was:
{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.



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