代碼:
從pyspark.sql。功能導入*
acDF = spark.read.format (csv)。選項(頭=‘真正的’,inferschema = '真的').load (“/ mnt / rahulmnt / Insurance_Info1.csv”);
acDF.write。選項(“overwriteSchema”,“真正的”).format .mode(“δ”)(“覆蓋”).save(“/δ/ InsuranceInput”)
錯誤:
AnalysisException:“檢測到不兼容的格式。\ n \ nYou試圖寫入
/δ/ InsuranceInput
使用磚三角洲,但是沒有\ ntransaction日誌。檢查確保它的上遊工作是寫作\新加坡國立大學格式(“δ”),你要寫的基本路徑。\ n \全家人禁用這張支票,而設置spark.databricks.delta.formatCheck.enabled = false \學習更多關於三角洲,明白了https://docs.azuredatabricks.net/delta/index.html \ n,“
