把錯誤當試圖加載在py筆記本電腦上傳文件。
#文件位置和類型file_location = " / / FileStore /表/數據/ d1.csv”
file_type = " csv "
# CSV選項
infer_schema = " true "
first_row_is_header = " false "
分隔符= ","
# CSV文件的應用選項。對於其他類型的文件,這些將被忽略。
df = spark.read.format (file_type)
infer_schema .option (“inferSchema”)
.option(“標題”,first_row_is_header)
.option(“9”,分隔符)
.load (file_location)
顯示器(df)
錯誤突出顯示的行:
Py4JJavaError回溯(去年)最近調用<命令- 2996484959822084 > <模塊> ()9 10 # CSV文件的應用選項。對於其他類型的文件,這些將被忽略。推薦- - - - - - > 11 df = spark.read.format (file_type)。選項(“inferSchema”, infer_schema)。選項(“標題”,first_row_is_header)。選項(“9”,分隔符).load (file_location) 12 13顯示(df) /磚/火花/ python / pyspark / sql /讀寫。py負載(自我、路徑、格式、模式* *選項)164年self.options(* * 165(選項)如果isinstance(路徑,basestring): - - > 166年回歸自我。df (self.jreader.load(路徑))167 elif路徑isnotNone: 168如果類型(路徑)!=列表:/磚/火花/ python / lib / py4j-0.10.7-src.zip / py4j / java_gateway。py在呼叫(自我,* args) 1255回答= self.gateway_client.send_command(命令)1256 return_value = get_return_value(- > 1257回答,自我。gateway_client self.target_id,self.name)1258
