You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@hudi.apache.org by "Alexey Kudinkin (Jira)" <ji...@apache.org> on 2022/03/15 22:46:00 UTC

[jira] [Created] (HUDI-3639) [Incremental] Add Proper Incremental Records FIltering support into Hudi's custom RDD

Alexey Kudinkin created HUDI-3639:
-------------------------------------

             Summary: [Incremental] Add Proper Incremental Records FIltering support into Hudi's custom RDD
                 Key: HUDI-3639
                 URL: https://issues.apache.org/jira/browse/HUDI-3639
             Project: Apache Hudi
          Issue Type: Bug
            Reporter: Alexey Kudinkin


Currently, Hudi's `MergeOnReadIncrementalRelation` solely relies on `ParquetFileReader` to do record-level filtering of the records that don't belong to a timeline span being queried.

As a side-effect, Hudi actually have to disable the use of [VectorizedParquetReader|https://jaceklaskowski.gitbooks.io/mastering-spark-sql/content/spark-sql-vectorized-parquet-reader.html] (since using one would prevent records from being filtered by the Reader)

 

Instead, we should make sure that proper record-level filtering is performed w/in the returned RDD, instead of squarely relying on FileReader to do that.



--
This message was sent by Atlassian Jira
(v8.20.1#820001)