Začněte nyníZačněte zdarma

Vše dohromady II

Vytvoř DataFrame, proveď transformace, ulož ho do mezipaměti a ověř, zda je uložen. Poté ho z mezipaměti uvolni a vrať paměť zpět. Pro toto cvičení je relace spark již připravena! Pozorně sleduj výstup metody .explain() a pochop, co ti říká!

Toto cvičení je součástí kurzu

Introduction to PySpark

Zobrazit kurz

Pokyny k cvičení

  • Ulož DataFrame df do mezipaměti.
  • Vysvětli zpracování DataFrame agg_result.
  • Po dokončení zpracování uvolni DataFrame df z mezipaměti pomocí .unpersist().

Interaktivní cvičení na vyzkoušení si v praxi

Vyzkoušejte si toto cvičení dokončením tohoto ukázkového kódu.

# Cache the DataFrame
df.____

# Perform aggregation
agg_result = df.groupBy("Department").sum("Salary")
agg_result.show()

# Analyze the execution plan
agg_result.____

# Uncache the DataFrame
df.____
Upravit a spustit kód