如何在 Spark Scala 中转换为 Long？

Question

这似乎是一个简单的任务，但我不知道如何在 Spark（而不是 PySpark）中使用 Scala 来完成它。我有一个df包含不同列的数据框。其中一列的类型String应更改为Long。我该怎么做？

如果我执行此代码，我会收到编译错误Cannot resolve symbol col：

df.withColumn("timestamp", col("timestamp").cast(LongType))

Answer 1

我认为你需要导入org.apache.spark.sql.functions.col才能使用col()函数。