spark dataframe时间戳和日期之间的转换
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 = Facedf
·
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"))
更多推荐
所有评论(0)