PySpark - Data processing in Python on top of Apache Spark.
summary
PySpark exposes the Apache Spark programming model to Python and claims declarative DataFrame API queries get the same optimized speed as Scala via the catalyst optimizer while lower‑level Resilient Distributed Datasets stay lazy and fault‑tolerant. Demo loads JSON GitHub event files (tens of millions of rows), runs counts and top‑committer aggregations on a cluster (four machines ~40 cores each, ~1 TB total), and returns small results — live demo mostly succeeds though cluster UI visibility falters.
AI-written summary · about
chapters (14)
- 0:00Introduction
- 2:55RDD
- 4:41Transformations
- 5:36MapReduce
- 6:16Partitions
- 7:17What is PySpark
- 8:42How it works
- 10:48Userdefined functions
- 13:27Data Source
- 14:05PySpark Data Format
- 15:15Prediction Projection
- 16:05DataFrame
- 16:31Schema
- 22:14Summary
related talks
45mIndroduction to the PySpark DataFrame API
50mBig Data Processing and Data Science Environment in Python
01h 22mIntroduction to Big Data Processing using Spark and Python
43mPySpark in Practice
31mBringing the Jewels of the Python World to Scala with Spark
25mScale Data Science by Pandas API on Spark
05mBig Data, No Big Deal: PySpark
25mDistributed data workflows: PySpark vs Dask
