请先关注 [低调大师] 公众号 优秀的自媒体个人博客,低调大师,许军

低调大师

您现在的位置是:首页>文章详情

文章详情

Apache Spark Delta Lake 删除使用及实现原理代码解析

2019-09-26 104热度

Apache Spark Delta Lake 删除使用及实现原理代码解析

Delta Lake 的 Delete 功能是由 0.3.0 版本引入的。在介绍 Apache Spark Delta Lake 实现逻辑之前,我们先来看看如何使用 delete 这个功能。

Delta Lake 删除使用

Delta Lake 的官方文档为我们提供如何使用 Delete 的几个例子,参见这里,如下:

import io.delta.tables._   val iteblogDeltaTable = DeltaTable.forPath(spark, path)   // 删除 id 小于 4 的数据 iteblogDeltaTable.delete("id <= '4'")   import org.apache.spark.sql.fu
收藏 (0)

相关文章

    文章评论

    共有0条评论来说两句吧...