在Scala中将整个列强制转换为火花时间戳[重复]

Question

我有一个dataframedf，其架构如下：

ts:double
key:long
val:long

val new_df = df.select($"ts".cast(TimestampType))

val new_df = df.map(udf(col("ts")) 

Answer 1

您只需要with column:

df.withColumn("ts", $"ts".cast(TimestampType))

或简单的选择，并使用*:

df.select($"*", $"ts".cast(TimestampType))