не могли бы вы помочь мне с этим.

я есть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

Ответы на вопрос(2)

Ваш ответ на вопрос