Eliminarea unui DataFrame din cache

Ai terminat sarcinile de analiză cu DataFrame-ul departures_df, dar mai ai și alte operații de efectuat. Vrei să elimini DataFrame-ul din cache pentru a evita consumul inutil de memorie pe cluster.

DataFrame-ul departures_df este definit și a fost deja adăugat în cache pentru tine.

Acest exercițiu face parte din cursul

Curățarea datelor cu PySpark

Vezi cursul

Instrucțiuni pentru exercițiu

Verifică starea de caching a DataFrame-ului departures_df.
Elimină DataFrame-ul departures_df din cache.
Validează din nou starea de caching.

Exercițiu interactiv practic

Încearcă acest exercițiu completând acest cod de exemplu.

# Determine if departures_df is in the cache
print("Is departures_df cached?: %s" % departures_df.____)
print("Removing departures_df from cache")

# Remove departures_df from the cache
____

# Check the cache status again
print("Is departures_df cached?: %s" % ____)

Editează și rulează codul