如何在Pyspark中向现有日期列添加十天

toiithl6 于 2023-03-01 发布在 Spark

关注(0)|答案(1)|浏览(117)

我在Pyspark中有一个 Dataframe ，其中包含一个名为"report_date"的日期列。
我想创建一个名为"report_date_10"的新列，该列将在原始report_date列的基础上添加10天。
下面是我尝试的代码：

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

这是我得到的错误：
属性错误："datetime. timedelta"对象没有属性"_get_object_id"
救命!谢谢

pyspark

来源：https://stackoverflow.com/questions/50703284/how-to-add-ten-days-to-existing-date-column-in-pyspark

1条答案

按热度按时间

l5tcr1uw1#

您似乎使用了pandas语法来添加列;对于spark，您需要使用withColumn添加一个新列;为了添加日期，有内置的date_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|
+-----------+--------------+

赞(0）回复(0）举报 2023-03-01

我来回答

如何在Pyspark中向现有日期列添加十天

1条答案

相关问题

热门标签

最新问答