Nou Generator de prompt AI — scrie prompturi mai bune pentru ChatGPT, Claude și Gemini →

Deduplicarea Datelor Globale cu df.distinct în Apache Spark & PySpark

dataframe Apache Spark 3.5 / PySpark Q&A / Distribuie cod

Eliminarea automată a rândurilor identice din întregul DataFrame prin agregare hash distribuită.

Sintaxă
df.distinct()

Metoda df.distinct() returnează un DataFrame care conține doar rândurile unice, comparând toate coloanele disponibile. Spre deosebire de dropDuplicates() (care permite selectarea unui subset de coloane cheie), distinct() garantează unicitatea întregii tuple.

Din punct de vedere al execuției, distinct() implică o etapă de Shuffling, grupând rândurile cu aceeași valoare hash pe aceiași executori pentru comparare.

Exemplu: Eliminarea dublurilor dintr-o listă de categorii
df_categorii = df_produse.select("departament", "categorie").distinct()

print(f"Număr categorii unice: {df_categorii.count()}")
df_categorii.show(10)

Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: Deduplicarea Datelor Globale cu df.distinct

Ai o nelămurire despre utilizarea comenzii Deduplicarea Datelor Globale cu df.distinct sau ai descoperit un truc / fragment de cod util? Distribuie-l cu ceilalți programatori!

💬

Fii primul care pune o întrebare sau distribuie un fragment de cod / prompt!

Nu au fost adăugate încă întrebări sau exemple de cod pentru această pagină. Dacă ai întâlnit o problemă sau ai un snippet util, adaugă-l mai jos pentru a-i ajuta pe ceilalți.

Comunitate Adaugă o întrebare sau distribuie un cod

Moderare & Siguranță:

Pentru a menține calitatea și securitatea informațiilor, fiecare întrebare sau fragment de cod/prompt este analizat (manual sau prin moderare asistată de AI) înainte de publicare.