Saltar al contenido

¿Cómo restar una columna de días de una columna de fechas en Pyspark?

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)



Utiliza Nuestro Buscador

Deja una respuesta

Tu dirección de correo electrónico no será publicada. Los campos obligatorios están marcados con *