Geser Dugarov
Geser Dugarov
### Change Logs Fixed unit test in TestJavaHoodieBackedMetadata, and TestHoodieDeltaStreamer. ### Impact Fixed unit tests. ### Risk level (write none, low medium or high below) Low. ### Contributor's checklist -...
### Change Logs `KeyGenUtils::extractRecordKeysByFields` is used in Flink stream processing with buckets. Optimization of this part is critical because it's called from `BucketStreamWriteFunction::processElement`, which means it's called for each record....
### Change Logs `DataBucket::preWrite` sets new current location, using `fileID` from `DataBucket`, only for first record in the bucket. But `fileID` is set only during `DataBucket` initialization, where we use...