2023年12月11日发(作者：)

SparkDataFrame如何更改列column的类型

如下示例，通过最初json文件所生成的df的age列是Long类型，给它改成其他类型。当然不止如下两种方法，但我觉得这是最为简单的两

种了

val spark = r().master("local").appName("DataFrame API").getOrCreate()

// 读取spark项目中example中带的几个示例数据，创建DataFrame

val people = ("json").load("data/")

()

chema()

val p = Expr("cast(age as string) age_toString","name")

chema()

import its._ //导入这个为了隐式转换，或RDD转DataFrame之用

import pes

people withColumn("age", $"age".cast(rType)) //DataTypes下有若干数据类型，记住类的位置

chema()

参考这个：