2

我创建了一个这样的表并插入了一些数据

spark.sql(s"create table if not exists test " +
"(key String," +
"name String," +
"address String," +
"inserted_at TIMESTAMP) " +
s"  using delta  LOCATION 's3://test/user/'")

我可以通过查看表格

spark.table("test").show()

但是当我这样做时

DeltaTable.forPath(spark,"s3://test/user/" ).toDF.show(false)

我看不到数据。但是当我尝试这种方法时

DeltaTable.isDeltaTable("s3://test/user/")

是真的。谁能解释我错过了什么?

此外,当我想做一个合并操作时,我收到了这个错误。

[error] ! 
[error]  java.lang.UnsupportedOperationException: null (DeltaTable.scala:639)
[error] io.delta.tables.DeltaTable$.forPath(DeltaTable.scala:639)
4

0 回答 0