如何在 Spark Scala 中转换为 Long？
How to cast to Long in Spark Scala?
这似乎是一项简单的任务，但我不知道如何在 Spark（不是 PySpark）中使用 Scala 来完成它。
我有一个包含不同列的 DataFrame df。其中一列的类型 String 应更改为 Long。我该怎么做？
如果我执行这段代码，我会得到编译错误 Cannot resolve symbol col:
df.withColumn("timestamp", col("timestamp").cast(LongType))
我认为您需要导入 org.apache.spark.sql.functions.col 才能使用 col() 功能。
这似乎是一项简单的任务，但我不知道如何在 Spark（不是 PySpark）中使用 Scala 来完成它。
我有一个包含不同列的 DataFrame df。其中一列的类型 String 应更改为 Long。我该怎么做？
如果我执行这段代码，我会得到编译错误 Cannot resolve symbol col:
df.withColumn("timestamp", col("timestamp").cast(LongType))
我认为您需要导入 org.apache.spark.sql.functions.col 才能使用 col() 功能。