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
Pokyny k cvičení
- Ulož DataFrame
dfdo mezipaměti. - Vysvětli zpracování DataFrame
agg_result. - Po dokončení zpracování uvolni DataFrame
dfz 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.____