scala – 如何从字符串中获取日期和时间？

val unix = unix_timestamp($"date","yyyyMMddHHmm").alias("unix")

转换为timestmap：

val ts = unix.cast("timestamp").alias("ts")

到目前为止获取日期：

val dt = ts.cast("date").alias("dt")

使用小时/分钟来获取时间：

val h = hour(ts).alias("h")
val m = minute(ts).alias("m")

例：

import org.apache.spark.sql.functions._

val df = Seq((1L,"201605250000")).toDF("id","date")
df.select($"*",unix,ts,dt,h,m).show

// +---+------------+----------+--------------------+----------+---+---+
// | id|        date|      unix|                  ts|        dt|  h|  m|
// +---+------------+----------+--------------------+----------+---+---+
// |  1|201605250000|1464127200|2016-05-25 00:00:...|2016-05-25|  0|  0|
// +---+------------+----------+--------------------+----------+---+---+

注意：对于1.5使用unix.cast(“double”).cast(“timestamp”)