scala - 見つかりません: 値 udf エラー

Question

コードで次のように定義された udf があります。

val toOriginalTimestamp = udf((timestamp: String) => timestamp.substring(0, 18))

データセットのタイムスタンプ フィールドの部分文字列を取得しようとしています。ただし、見つからないというエラーが表示されます: value udf

私は何を間違っていますか？

Answer 1

おそらくこれが必要です：

import org.apache.spark.sql.functions.udf

また、spark-sql (spark-core だけでなく!) 1.3 以降の依存関係を使用していることを確認してください。