你好休伯特,
謝謝你的回答,但是我不能讓它工作。
讓我用不同的方式問這個問題。
我有一個csv文件與以下基本estruture:
在PySpark我想存儲文件模式:
我需要做什麼樣的轉換的變量1。能夠存儲在2。,反之亦然?
提前謝謝,
蒂亞戈R。
嗨@Tiago年金,希望這將有助於。
csv_file = spark.read.csv(“/道路/ /輸入/數據”,標題= True, 9 = "、");csv_file.write.format(“δ”).mode(“覆蓋”).option .save (“overwriteSchema”,“真正的”)(“/ mnt /δ/產品”)火花。sql(“使用三角洲位置創建表employee / mnt /δ/產品/”)