使用Delta库写入Deltatable需要添加Delta库的依赖,通过以下步骤解决:
export SPARK_SUBMIT_OPTIONS="--packages io.delta:delta-core_2.12:1.0.0"
重启Zeppelin服务。
在 Spark 代码中添加以下段落:
import io.delta.tables._ import org.apache.spark.sql.functions._
// 写入 deltaTable.toDF.write.format("delta").mode("append").save("/path/to/table")
// 读取 val readDF = spark.read.format("delta").load("/path/to/table")
希望这个解决方案可以帮助你解决Apache Zeppelin无法将Deltatable写入Spark的问题。