scala - Spark Scala 数据框列不匹配

Question

这在 DF 上运行良好。

val recs = spark.table("IIR").select($"dateFrom").withColumn("N", lit(5))
val rec2 = recs.withColumn("sellByDate", date_add(col("dateFrom"), 5))

但是，这不会：

val rec2 = recs.withColumn("sellByDate", date_add(col("dateFrom"), $"N"))

臭名昭著的消息是：

notebook:11: error: type mismatch;
  found   : String("$N")
  required: Int

最简单的方法是什么？

标签： scalaapache-spark