2016-08-15 15 views
0

上記の「spark 1.5 &」に「current_timestamp」関数がありますが、まだ1.4になっています。 「現在のタイムスタンプ」に設定されているDataFrameに列を追加するにはどうすればよいですか?Spark sql(1.4):現在のタイムスタンプを取得

df.withColumn("date_inserted", ????) 

答えて

1

シンプルなタイムスタンプのリテラルトリック実行する必要があります。

df.withColumn(
    "date_inserted", 
    lit(java.sql.Timestamp.from(java.time.Instant.now))) 
+0

うわーを!クール。これはタイムゾーンを与えませんが、それは問題ありません。私は今それで遊ぶことができます。ありがとう。 – DilTeam

関連する問題