我创建了一个这样的表并插入了一些数据
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)