Skip to content

Instantly share code, notes, and snippets.

@kywe665
Created July 14, 2022 07:31
hudi_delete_options = {
'hoodie.table.name': tableName,
'hoodie.datasource.write.recordkey.field': 'tpepPickupDateTime',
'hoodie.datasource.write.operation': 'delete',
'hoodie.datasource.write.precombine.field': 'tpepDropoffDateTime'
}
todelete.write.format("hudi").options(**hudi_delete_options).mode("append").save(basePath)
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment