Funcțiile F.lag() și F.lead() permit citirea valorii unei coloane din rândul anterior sau din cel următor în cadrul aceleiași partiții de date sortate. Sunt ideale pentru calcularea diferențelor de la o zi la alta (day-over-day), a duratei dintre sesiuni sau a variațiilor de preț.
Exemplu: Calculul diferenței de preț față de ziua precedentă
from pyspark.sql import functions as F
from pyspark.sql.window import Window
fereastra_actiune = Window.partitionBy("simbol_bursa").orderBy("data")
df_preturi = df.withColumn("pret_ziua_anterioara", F.lag("pret_inchidere", 1).over(fereastra_actiune)) \
.withColumn("variatie_zilnica", F.col("pret_inchidere") - F.col("pret_ziua_anterioara"))
df_preturi.show(5)
Întrebări & Exemple de Cod:
Accesarea Rândurilor Învecinate cu F.lead și F.lagAi o nelămurire despre utilizarea comenzii
Accesarea Rândurilor Învecinate cu F.lead și F.lagsau 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.