1

spark 1.5.x から、時間を処理するためにいくつかの便利なメソッドが追加されました。

df.select(datediff($"A", $"B")).show

しかし、これは差を日数で返します。年などの別の間隔に変換するオプションはありますか?

手動で使用しました

df.select(year($"A")- year($"B")).show

これで十分です。しかし、表示されているような月/日を含むなど、日付の差がより正確に計算された方が良いでしょう誕生/

UDF は現在の Spark 2.0.2 の主要なソリューションですか? または、差を日として年に変換するオプションがありませんか?

4

1 に答える 1