Uploaded image for project: 'Flink'
  1. Flink
  2. FLINK-21520

ParquetInputFormat#setfilterPredicate() does not work

Attach filesAttach ScreenshotAdd voteVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

      Description

      Simplified code:

       FilterPredicate filterPredicate = eq(intColumn("intField"), 10);
      parquetInputFormat.setFilterPredicate(filterPredicate);
      env.createInput(parquetInputFormat);
      

      produces no records whereas

      env.createInput(parquetInputFormat)
      .filter((FilterFunction) value ->  value.get("intField") == 10);
      

      produces records.

        Attachments

          Activity

            People

            • Assignee:
              Unassigned
              Reporter:
              echauchot Etienne Chauchot

              Dates

              • Created:
                Updated:

                Issue deployment