在了解 DataFrame 的強大之後,我們終於要讓 PySpark 處理真實世界的資料了!在企業的大數據專案中,資料來源五花八門,最常見的莫過於傳統的 CSV 報表、Web API 常用的 JSON 格式,以及在大數據生態系中佔有統治地位的 Parquet。今天這篇文章,我們將實作這三種格式的讀取與寫出,並解析為什麼大數據工程師都獨鍾 Parquet!
1. 傳統辦公室的最愛:CSV 格式
CSV (Comma-Separated Values) 是最平易近人的格式,幾乎所有的試算表軟體都能打開它。但在分散式運算中,CSV 有兩個致命傷:第一,它沒有自帶嚴謹的型態定義 (Schema),Spark 必須多花時間掃描推斷;第二,它讀取與切割的速度較慢。


