VOL. 01
YOUR SPARK KNOWLEDGE, RECONNECTED

Big ideas.
Smaller partitions.

A place to rebuild your Spark fundamentals, follow the data,
and walk into your next interview with a clearer head.

One dataset split into three partitions, with work running independently on each partition.01 — DIVIDE THE DATA. SHARE THE WORK.
20 linked lessons01 interactive visual lab145 interview promptsRead. Run. Explain it back.
FROM YOUR INTERVIEWS“Walk me through the full Spark flow.”Startup → query planning → tasks → shuffle → result. A verified walkthrough. YOUR NEXT PRACTICEPredict what Spark will do.Three snippets. Predict the tasks and data movement, reveal the reasoning, then verify it.THE SENIOR ROUNDDesign the pipeline out loud.CDC, backfills, data quality, and recovery, with a repeatable answer framework.
THE LEARNING PATH

First, get the foundations right.

CHAPTER 01

Follow the sequence, or pick up the concept you need today.

01 / THE FUNDAMENTALS

01

What is Apache Spark?

Start with the problem Spark solves, before the API you write.

5 min
02

Driver, executors & the cluster

Know who plans the work and who actually runs it.

6 min
03

RDDs, DataFrames & Spark SQL

Choose the right abstraction for a data engineering pipeline.

5 min
04

Lazy evaluation & actions

Understand why a line of code is not a job.

6 min
05

Jobs, stages & tasks

Read the execution hierarchy without memorizing misleading formulas.

6 min
06

Partitions & shuffles

Follow the data when work needs to cross partition boundaries.

7 min
07

Joins & data skew

Reason about data shape before reaching for a join hint.

7 min
08

Caching & fault tolerance

Reuse the right work, and know what Spark can recompute.

6 min
09

Executor memory, spill & out-of-memory errors

Understand where an executor's memory goes, why Spark spills to disk, and how to read an out-of-memory failure.

8 min
10

Reading the Spark UI and fixing slow jobs

Start from the slowest stage, compare tasks, then read the SQL plan before changing anything.

8 min
11

Catalyst, code generation & AQE

Follow a DataFrame from parsed plan to executed plan, read what explain prints, and see what adaptive execution changes once real sizes arrive.

12 min
12

PySpark UDFs, Arrow & the Python boundary

See where your Python function actually runs, what crosses into it, and why the fastest UDF is usually the one you did not need to write.

11 min
13

Storage formats: Parquet, ORC & Avro

Why the file layout decides what your query reads — and why small files are fatal.

9 min

02 / TABLES & STREAMS

14

Delta Lake: transactions, MERGE & maintenance

How an ordered log turns immutable Parquet files into a table, and what MERGE, OPTIMIZE, and VACUUM really cost.

14 min
15

Structured Streaming: micro-batches, state & exactly-once

What the driver plans each trigger, what the checkpoint records, and why late data and restarts behave the way they do.

12 min

03 / CONNECT & APPLY

16

The complete Spark execution flow

From spark-submit to the final result: explain who does what, when, and why.

18 min
17

Predict what Spark will do

Three interview exercises. Read the code, predict the work, then check your reasoning against the plan and Spark UI.

25 min
18

Count the jobs, stages, and tasks

Eight practice snippets measured with the Spark UI REST API, with AQE on and off, so you can give counts along with the assumptions that make them true.

40 min
19

The PySpark coding round: six patterns

Six problems that recur in 30–45 minute data engineering coding rounds — each solved, run, and costed, with the wrong answer that looks right.

25 min
20

Designing data pipelines: the senior round

A repeatable answer shape, and the idempotent, ordered, recoverable write paths that make a design survive a rerun.

14 min

Find a concept