如何从scala数据框中的日期列值中检索月份？

Question

鉴于：

val df = Seq((1L, "04-04-2015")).toDF("id", "date")
val df2 = df.withColumn("month", from_unixtime(unix_timestamp($"date", "dd/MM/yy"), "MMMMM"))
df2.show()

我得到了这个输出：

+---+----------+-----+
| id|      date|month|
+---+----------+-----+
|  1|04-04-2015| null|
+---+----------+-----+

但是，我希望输出如下：

+---+----------+-----+
| id|      date|month|
+---+----------+-----+
|  1|04-04-2015|April|
+---+----------+-----+

我如何使用 Scala 在 sparkSQL 中做到这一点？

Answer 1

这应该这样做：

val df2 = df.withColumn("month", date_format(to_date($"date", "dd-MM-yyyy"), "MMMM"))

df2.show
+---+----------+-----+
| id|      date|month|
+---+----------+-----+
|  1|04-04-2015|April|
+---+----------+-----+

笔记：

• 第一个字符串 (to_date) 必须与您现有日期的格式匹配
  • 小心：“dd-MM-yyyy”与“MM-dd-yyyy”
• 第二个字符串（date_format）是输出的格式

文档：

• 迄今为止
• 日期格式