spark dataframe时间戳和日期之间的转换

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

日期格式转换为时间戳:

val Facedf = Facedf1.withColumn("time_unix",unix_timestamp(col("time"),"yyyy-MM-dd HH:mm:ss"))

时间戳格式转换为日期:

val Facedf = Facedf1.withColumn("time_date",from_unixtime(col("time_unix")))

.withColumn("trade_time",from_unixtime(col("startDate"),"yyyy-MM-dd HH:mm:ss"))

Logo

腾讯云面向开发者汇聚海量精品云计算使用和开发经验,营造开放的云计算技术生态圈。

更多推荐