Как разыграть Лонга в Spark Scala?

Question

Это кажется простой задачей, но я не могу понять, как это сделать с помощью Scala в Spark (не PySpark). У меня есть DataFrame df с разными столбцами. Один из столбцов имеет тип String, который следует изменить на Long. Как я могу это сделать?

Если я выполню этот код, я получу ошибку компиляции Cannot resolve symbol col:

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

Answer 1

Я думаю, вам нужно импортировать org.apache.spark.sql.functions.col, чтобы использовать col() функцию.