提问者:小点点

Pyspark:如何添加十天到现有的日期列


我在Pyspark中有一个数据框,其中有一个名为“report\u date”的日期列。

我想创建一个名为“report_date_10”的新列,该列将在原始report_date列中添加10天。

下面是我尝试的代码:

df_dc["report_date_10"] = df_dc["report_date"] + timedelta(days=10)

这是我得到的错误:

AttributeError:'日期时间。timedelta'对象没有属性'\u get\u object\u id'

帮助谢谢


共1个答案

匿名用户

似乎您正在使用pandas语法添加列;对于spark,需要使用with column添加新列;要添加日期,有内置的date\u add功能:

import pyspark.sql.functions as F
df_dc = spark.createDataFrame([['2018-05-30']], ['report_date'])

df_dc.withColumn('report_date_10', F.date_add(df_dc['report_date'], 10)).show()
+-----------+--------------+
|report_date|report_date_10|
+-----------+--------------+
| 2018-05-30|    2018-06-09|
+-----------+--------------+