Metoda pivot() transpune valorile dintr-o coloană categorială în coloane orizontale distincte, calculând simultan o funcție de agregare (sumă, medie, numărare). Este echivalentul direct al tabelelor pivot din Excel sau a clauzei PIVOT din SQL.
Pentru a preveni scanarea de două ori a datelor, este o bună practică de performanță să transmiteți lista explicită de valori posibile ca al doilea argument al metodei pivot().
Exemplu: Tabel pivot cu vânzările anuale per client
from pyspark.sql import functions as F
ani_analizati = [2024, 2025, 2026]
df_pivot = df_vanzari.groupBy("nume_client") \
.pivot("an", ani_analizati) \
.agg(F.sum("valoare_comanda")) \
.na.fill(0)
df_pivot.show(5)
Întrebări & Exemple de Cod:
Transpunerea Datelor Categoriale cu df.groupBy().pivot()Ai o nelămurire despre utilizarea comenzii
Transpunerea Datelor Categoriale cu df.groupBy().pivot()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.