spark/internals
advanced
Connecting…

Catalyst optimizer

Catalyst rewrites your query four times. Exchange in the physical plan is the shuffle you will pay for.

Explain it at my level

  1. Unresolved
  2. Analyzed
  3. Optimized
  4. Physical
  1. 1. Unresolved logicalunresolved attributes
  2. 2. Analyzed logicalcatalog + types bound
  3. 3. Optimized logicalpredicate pushdown, column prune
  4. 4. Physical planFileScan → Exchange → HashAggregate