我在Delta位置写入数据时遇到以下问题。我得到的数据不正确。我正在Azure Databricks中使用Python Notebook。使用的数据集:/databricks-datasets/flights/下面是我执行的步骤。 挂载到blob存储。dbutils.fs.mount(
source = "wasbs://[email protected]",
mount_point = "/mnt/blobstorage",
extra_configs = {'fs.azure.account.key.storageaccount7830.blob.core.windows.net':'accountKey'}
)保存到Delta表中fulldf = spark.read.format("csv").option("header",True).option("inferSchema",True).load('/databricks-datasets/flights/')
fulldf.write.format("delta").mode("overwrite").save("/mnt/blobstorage/Full")选择限制10的数据df=fulldf.limit(10)
df.write.format("delta").mode("overwrite").save("/mnt/blobstorage/Small")显示数据,我得到的输出是这样的。%sql
select * from delta.`/mnt/blobstorage/Small`![](https://i.stack.imgur.com/NtRkY.jpg) 输出应该是这样的。![](https://i.stack.imgur.com/6LxZ4.jpg)
|