2 votes

Comment convertir en Long dans Spark Scala?

Cela semble être une tâche simple, mais je n'arrive pas à comprendre comment le faire avec Scala dans Spark (pas PySpark). J'ai un DataFrame df avec différentes colonnes. L'une des colonnes a un type String qui devrait être changé en Long. Comment puis-je faire cela?

Si j'exécute ce code, j'obtiens l'erreur de compilation Cannot resolve symbol col:

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

3voto

himanshuIIITian Points 3200

Je pense que vous devez importer org.apache.spark.sql.functions.col pour utiliser la fonction col().

Prograide.com

Prograide est une communauté de développeurs qui cherche à élargir la connaissance de la programmation au-delà de l'anglais.
Pour cela nous avons les plus grands doutes résolus en français et vous pouvez aussi poser vos propres questions ou résoudre celles des autres.

Powered by:

X