延續我們的 online_retail 資料集,你的主管想了解各國的取消訂單模式。由於 SQL 在彙總與分組上通常更容易閱讀,你將用 SQL 查詢資料,並檢視執行計畫以確認 Spark 如何處理你的查詢。
online_retail
在這個練習中,你會從已篩選的 DataFrame 建立一個暫存檢視,執行 SQL 彙總,並檢視查詢計畫。
本練習屬於課程
將理論付諸實踐,立即體驗我們的互動練習
在本章中,你將學會使用 Databricks 筆記本、將 CSV 資料載入為 Spark DataFrame,並透過 PySpark 與 SQL 進行資料塑形。
當前練習
學習如何明確定義結構、建立資料清理管線,並透過廣播連接最佳化查詢效能。
學習如何使用視窗函式計算累積總和與排名、建立串流管線,並部署生產環境工作流程。