Este enunciado ha sido analizado por especialistas así se asegura la exactitud de nuestra esta división.
Solución:
Usar expr
función (si tiene dynamic values
de columnas a restar):
>>> from pyspark.sql.functions import *
>>> df.withColumn('substracted_dates',expr("date_sub(date_col,days_col)"))
Usar conColumna función (si tiene literal values
restar):
>>> df.withColumn('substracted_dates',date_sub('date_col',))
Pude resolver esto usando selectExpr
.
df.selectExpr('date_sub(date_col, day_col) as subtracted_dates')
Si desea agregar la columna al DF original, simplemente agregue *
a la expresión
df.selectExpr('*', 'date_sub(date_col, day_col) as subtracted_dates')
Si tienes algún recelo y capacidad de arreglar nuestro crónica puedes dejar una referencia y con deseo lo observaremos.
¡Haz clic para puntuar esta entrada!
(Votos: 0 Promedio: 0)