Options
- Mark as New
- Bookmark
- Subscribe
- Mute
- Subscribe to RSS Feed
- Permalink
- Report Inappropriate Content
09-01-2022 01:41 AM
Thank you for the document. It's very helpful.
From the doc, I thought I would be able to use
deltaTable = DeltaTable.replace(sparkSession)
.tableName("testTable")
.addColumns(df.schema)
.execute()to update the schema in the code when some schema change is detected.
Anyway, this piece of code does replace the table, so not only the data got update, but all the data are also gone.
Do you have any other suggestion?