0
我知道上面的Spark 1.5 &中有'current_timestamp'函数,但我们仍然在1.4。如何将列添加到设置为'当前时间戳'的DataFrame?Spark sql(1.4):获取当前时间戳
df.withColumn("date_inserted", ????)
我知道上面的Spark 1.5 &中有'current_timestamp'函数,但我们仍然在1.4。如何将列添加到设置为'当前时间戳'的DataFrame?Spark sql(1.4):获取当前时间戳
df.withColumn("date_inserted", ????)
简单的时间戳文字应该做的伎俩:
df.withColumn(
"date_inserted",
lit(java.sql.Timestamp.from(java.time.Instant.now)))
哇!凉。这个不给时区,但没关系。我现在可以玩它了。谢谢。 – DilTeam