Manipularea Datelor Calendaristice: to_date și date_add în Apache Spark & PySpark

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

Parsarea șirurilor de caractere în tipuri Date/Timestamp și adăugarea de intervale temporale.

Sintaxă
F.to_date(col, fmt) / F.to_timestamp(col, fmt) / F.date_add(col, days)

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() și F.to_timestamp(): Parsează șiruri de text în tipuri native DateType sau TimestampType conform unui format specificat (ex. yyyy-MM-dd HH:mm:ss).
  • F.date_add() și F.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)

Comunitate & Schimb de cunoștințe

Întrebări & Exemple de Cod: Manipularea Datelor Calendaristice: to_date și date_add

Ai o nelămurire despre utilizarea comenzii Manipularea Datelor Calendaristice: to_date și date_add 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.