не могли бы вы помочь мне с этим.
я естьdataframe
DF изcolumns
("id", "current_date", "days")
и я пытаюсь добавить "days
"до"current_date
"и создать новыйdataframe
с новымcolumn
называется "new_date
"используя искровую функцию скалаdate_add()
val newDF = df.withColumn("new_Date", date_add(df("current_date"), df("days").cast("Int")))
Но выглядит как функцияdate_add
только принимаетInt
ценности, а неcolumns
, Как получить желаемый результат в таком случае? Есть ли альтернативные функции, которые я могу использовать, чтобы получить желаемый результат?
версия spark: 1.6.0 версия scala: 2.10.6