Funcția F.datediff(end_date, start_date) calculează diferența în număr întreg de zile dintre două date calendaristice. Dacă data finală este anterioară celei inițiale, funcția returnează o valoare negativă.
Pentru analize de churn sau vechimea contractelor, F.months_between() calculează numărul de luni scurse, oferind opțiunea de a returna rezultatul cu precizie fracționară sau rotunjit.
Exemplu: Calcularea vechimii clienților în zile și luni
from pyspark.sql import functions as F
df_vechime = df.withColumn(
"zile_de_la_inregistrare",
F.datediff(F.current_date(), F.col("data_inregistrarii"))
).withColumn(
"luni_abonament",
F.round(F.months_between(F.current_date(), F.col("data_inregistrarii")), 1)
)
df_vechime.select("client_id", "zile_de_la_inregistrare", "luni_abonament").show(5)
Întrebări & Exemple de Cod:
Calculul Intervalelor Temporale cu F.datediffAi o nelămurire despre utilizarea comenzii
Calculul Intervalelor Temporale cu F.datediffsau 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.