我有一个场景,希望在Spark DataFrame
的日期列中添加月份,该列具有两个数据类型为(Date,Int)的列。
例如:
df.show()
data_date months_to_add
2015-06-23 5
2016-07-20 7
我想添加一个新列,该列将有一个新日期(在现有日期的基础上添加几个月),输出将如下所示 -
data_date month_to_add new_data_date
2015-06-23 5 2015-11-23
2016-07-20 1 2016-8-20
我已经尝试了以下代码,但似乎没有起作用-
df = df.withColumn("new_data_date", a
dd_months(col("data_date"), col("months_to_add")))
它给我报错-
'Column' object is not callable
请帮我找到不需要在数据框上使用SQL查询的方法来完成此操作。