Lucrul cu date temporale este fundamental în analiza seriilor de timp și rapoartele financiare. PySpark oferă o suită de funcții optimizate:
F.to_date()șiF.to_timestamp(): Parsează șiruri de text în tipuri nativeDateTypesauTimestampTypeconform unui format specificat (ex.yyyy-MM-dd HH:mm:ss).F.date_add()șiF.date_sub(): Adaugă sau scad un număr de zile calendaristice dintr-o dată dată.
Exemplu: Calcularea datei de scadență a facturilor
from pyspark.sql import functions as F
df_facturi = df.withColumn(
"data_emiterii",
F.to_date(F.col("data_sir"), "dd/MM/yyyy")
).withColumn(
"data_scadenta",
F.date_add(F.col("data_emiterii"), 30)
)
df_facturi.select("numar_factura", "data_emiterii", "data_scadenta").show(5)
Întrebări & Exemple de Cod:
Manipularea Datelor Calendaristice: to_date și date_addAi o nelămurire despre utilizarea comenzii
Manipularea Datelor Calendaristice: to_date și date_addsau 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.