读取现有增量表时未找到表或视图

问题描述

我是德拉莱克的新手。我正在尝试一个简单的例子。

  1. 从 csv 创建数据框
  2. 另存为增量表
  3. 再读一遍。

它工作正常。我可以看到文件是在认的 spark-warehouse 文件夹中创建的。

但是下次我只想阅读保存的表格。所以我注释了前两个 septs 的代码并重新运行我得到的程序

分析异常:未找到表或视图


 val transHistory = spark.
      read
      .option("header","true")
      .option("inferschema",true)
      .csv(InputPath + "trainHistory.csv");

    transHistory.write.format("delta").mode(SaveMode.Overwrite).saveAsTable("transactionshistory")

    val transHistoryTable = spark.read.format("delta").table("transactionshistory")
    transHistoryTable.show(10)

我使用的是 deltalake 0.8.0、Spark 3.0 和 Scala 2.12.13

解决方法

暂无找到可以解决该程序问题的有效方法,小编努力寻找整理中!

如果你已经找到好的解决方法,欢迎将解决方案带上本链接一起发送给小编。

小编邮箱:dio#foxmail.com (将#修改为@)