spark/internals
intermediate
Connecting…

The Spark DAG

The DAG is the graph of operators. Wide edges are shuffles. Reading the DAG is reading the cost.

Explain it at my level

  1. Nodes
  2. Edges
  3. Shuffle edge
read parquet
filter region
groupBy region
count() ⚡