An open-source storage framework that enables building a Lakehouse architecture with compute engines including Spark, PrestoDB, Flink, Trino, and Hive and APIs
It wraps two RoaringBitmapArray APIs readFrom and serializeAsByteArray with two utils function DeletionVectorUtils.serialize and DeletionVectorUtils.deserialize, which will log a delta event when it fails during (de-)serialization to enable monitoring and debugging the error.
Which Delta project/connector is this regarding?
Description
It wraps two
RoaringBitmapArrayAPIsreadFromandserializeAsByteArraywith two utils functionDeletionVectorUtils.serializeandDeletionVectorUtils.deserialize, which will log a delta event when it fails during (de-)serialization to enable monitoring and debugging the error.How was this patch tested?
Log-only change.
Does this PR introduce any user-facing changes?
No.