是的。三角洲實際上明確刷新dataframe緩存後執行刪除。
使用這段代碼來測試它。
Seq ((0,“A”), (1,“B”), (2,“C”)) .toDF .write.format (“id”、“價值”)(“δ”).mode .saveAsTable(“覆蓋”)(“target_tbl”) val df =火花。sql (“select * from target_tbl”) df.persist () df.show()火花。sql(“刪除從target_tbl id = 2”) df.show () df.unpersist()輸出:+ - - - +——+ | | id值| + - - - +——+ | 0 | | | 2 | C | | 1 | | B + - - - +——+ + - - - +——+ | | id值| + - - - +——+ | 0 | | | 1 | | B + - - - + - - - +
