我有一个流数据传入,我使用以下代码将其保存为 deltalake 表:
cast_dataframe.writeStream.format("delta").outputMode("append")
.option("checkpointLocation",checkpointLocation)
.table(databasename+"."+tablename)
这里 database 是数据库的名称,tablename 是用于创建表的表的名称。
当我使用show create table来显示表的架构时,位置字段指向一个随机位置,例如 abfs://storageaccount@storageaccount.dfs.core.net/default/db_name/table_name。但是,我想将该位置指向我指定的位置。我怎样才能做到这一点 ?
我尝试了以下方法,但没有奏效。
cast_dataframe.writeStream.format("delta").outputMode("append")
.option("checkpointLocation",checkpointLocation)
.table(databasename+"."+tablename)
.save(my_specified_location)
但是上面的方法不起作用。请帮我解决这个问题。