#pyspark

narrow filter/select 分區1 分區2 分區3 分區1 分區2 分區3 1對1,不搬 wide groupBy/join 分區1 分區2 分區3 shuffle:跨分區重新分配 輸出1 輸出2 輸出3

Spark DataFrame 實戰:讀取、轉換、寫出與 Spark SQL

· tech · 約 4 分鐘 · 📚 Spark 學習筆記 #2

上一篇把 Spark 的概念講完了:Driver / Executor、分區、惰性求值、shuffle。這篇動手用 DataFrame 實際轉一份資料 —— 讀進來、清洗、彙總、寫出去,並看看 Spa…

#spark#data-engineering#pyspark

Driver SparkSession · DAG Cluster Manager YARN / K8s Executor tasks + 分區 Executor tasks + 分區 Executor tasks + 分區 申請資源

Apache Spark 是什麼?一篇搞懂分散式資料處理

· tech · 約 5 分鐘 · 📚 Spark 學習筆記 #1

一句話:Apache Spark 是一個把「大到單台機器裝不下、算不完」的資料,切成很多份、分散到一整個叢集上平行運算的引擎。它源自 UC Berkeley(2009),2014 成為 Apache …

#spark#data-engineering#pyspark