磚

從pyspark.sql代碼:。功能導入* acDF = spark.read.format (csv)。選項(頭=‘真正的’,inferschema = '真的').load (“/ mnt / rahulmnt / Insurance_Info1.csv”);acDF.write。選項(“overwriteSchema”,“真正的”).format .mode(“δ”)(“覆蓋”).save(“/解決……