xloya opened a new pull request #3135:
URL: https://github.com/apache/iceberg/pull/3135


   
   **1. What this MR does:**
   When the equality delete set in DeleteFilter saves a piece of data read from 
an `equal delete` parquet file in memory, it will call the `get()` method of 
the `GenericRecord` class for data comparison.If the table schema definition of 
the current position of `GenericRecord` is `DATE/TIMESTAMP/TIME` type, it will 
be converted to `LocalDate/LocalDateTime/LocalTime` type in memory. When the 
`get()` method of `GenericRecord` is compared, the java class 
`Integer/Long/Long` defined in the `Types` enum of the `DATE/TIMESTAMP/TIME` 
type is passed in. Because the type data of` LocalDate/LocalDateTime/LocalTime` 
is not an instance of `Integer/Long/Long` type, an IllegalStateException with 
Not an intance of xxx is thrown.
   
   The pr first converts the data to the `InternalRecordWrapper` before saving 
the data in the equality delete set, and calls its `get()` method during 
comparison. If it is a type that needs to be converted such as 
`DATE/TIMESTAMP/TIME`, use the `transforms` parameter to convert, otherwise 
directly Output raw data type.
   **2. Which issue this PR fixes:**
   Fix issue #3119.
   
   @rdblue @chenjunjiedada @openinx Could you help to take a look at this PR? 
Thanks in advance!


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: [email protected]

For queries about this service, please contact Infrastructure at:
[email protected]



---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]

Reply via email to