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