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