以下のコードを使用して、デルタレイク テーブルとして保存しているストリーミング データを受信しています。
cast_dataframe.writeStream.format("delta").outputMode("append")
.option("checkpointLocation",checkpointLocation)
.table(databasename+"."+tablename)
ここで、database はデータベースの名前で、tablename はテーブルの作成に使用されるテーブルの名前です。
show create the 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)
しかし、上記のアプローチは機能しません。これで私を助けてください。