scala - spark scala数据框将1添加到列中的所有值

Question

我是火花数据框的新手。我有一个文本文件，其中包含类似的数据

schoolid,classid,studentid,subject,marks
bjs,5,111,hindi,23
bjs,5,222,maths,78
bjs,7,333,bio,89
bjs,1,444,chemistry,67
ghs,2,555,bio,78
ghs,2,666,phy,56
ghs,9,777,drawing,56

我想将此数据转换为数据框并将 1 添加到标记列下的每个值

所以我使用的代码是

val df = sparkSession.read.format("csv").option("header","true").load("samplefile1.txt")
 val newdf = df.select(col($"marks"+1)).show()

但我得到的错误是

type mismatch; found : org.apache.spark.sql.Column required: String

我能得到正确语法的帮助吗

标签： scalaapache-sparkdataframe

Answer 1

试试这个解决方案：

df.withColumn("marks",col("marks") + lit(1)).show