我正在使用 spark 和 scala。我的以下代码在 spark-shell 上运行良好,但是当我尝试将其移至 Intelij 时,它会抛出错误,指出无法找到 split
。
我缺少什么,我需要导入什么才能使 split
工作
var outputDF = inputDF.withColumn(srcColumn,
split(inputDF.col(srcColumn),splitBy).getItem(selectIndex))
最佳答案
你可能错过了这个导入:
import org.apache.spark.sql.functions._
(在 Spark shell 中自动提供)
关于scala - 将拆分与数据框一起使用时出现未找到错误,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/45446804/