小编VNK*_*VNK的帖子

检查数据块中的路径上是否存在增量表

在加载之前,我需要从 delta-lake 表中删除某些数据。我可以从增量表中删除数据(如果存在),但当表不存在时会失败。

下面的 Databricks scala 代码

// create delete statement
val del_ID = "Check_ID =" + "123"

// get delta table from path where data exists
val deltaTable = DeltaTable.forPath(spark, path)

// delete data from delta table
deltaTable.delete(del_ID)
Run Code Online (Sandbox Code Playgroud)

仅当该路径上存在增量数据时,上述代码才有效,否则将失败。

有人可以分享一种方法,如果增量数据存在,则执行删除语句,否则删除语句将被忽略?

scala databricks delta-lake

11
推荐指数
2
解决办法
3万
查看次数

标签 统计

databricks ×1

delta-lake ×1

scala ×1