我知道 Spark 1.5 及更高版本中有一个“current_timestamp”函数,但我们仍然使用 1.4。如何向设置为“当前时间戳”的 DataFrame 添加一列?
df.withColumn("date_inserted", ????)
最佳答案
简单的时间戳文字应该可以解决问题:
df.withColumn(
"date_inserted",
lit(java.sql.Timestamp.from(java.time.Instant.now)))
关于java - Spark sql(1.4): Get current timestamp,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/38959349/