Я использую spark и мне нужно применить файлы cdc из реплики базы данных к файлу паркета, как upsert.Я уже сделал код для получения последнего состояния каждого идентификатора в файле Cdc, но теперь мне нужно применить эти последние состояния на историческом паркете.