在spark-scala数据帧中获取当前本地时间或系统时间可以通过以下步骤实现:
import org.apache.spark.sql.functions._
import java.time.LocalDateTime
current_timestamp()
函数获取当前时间:val currentTime = current_timestamp()
val localTime = currentTime.cast("timestamp").as("local_time")
val dfWithLocalTime = df.withColumn("local_time", localTime)
完整的代码示例:
import org.apache.spark.sql.functions._
import java.time.LocalDateTime
val currentTime = current_timestamp()
val localTime = currentTime.cast("timestamp").as("local_time")
val dfWithLocalTime = df.withColumn("local_time", localTime)
这样,你就可以在dfWithLocalTime
数据帧中获取到当前的本地时间或系统时间。
领取专属 10元无门槛券
手把手带您无忧上云