タイムフレーム列からのデータフレーム - 分。

Question

環境：Spark 1.6; Scala

簡単な質問ですが、私は正確な答えを得られませんでした。私はデータフレームを持っています

id | cr_date 
----------------------- 
1| 2017-03-17 11:12:00 
---------------------- 
2|2017-03-17 15:10:00 

cr_dateからマイナス5分必要です。私は//

任意の提案を動作しませんでした

val DF2= DF.select ($"cr_Date".cast("timestamp").minusMinutes(5))を試してみましたか？ おかげ

Answer 1

df.select(from_unixtime(unix_timestamp(col("cr_dt")).minus(5 * 60), "YYYY-MM-dd HH:mm:ss")) 

スパークで利用できるようにminusMinutes方法はありません。 上記のコードは、予期した結果を返します。