Pyspark:如何将值追加到列的开头？

在Pyspark中，可以使用withColumn()方法将值追加到列的开头。具体步骤如下：

from pyspark.sql import SparkSession
from pyspark.sql.functions import col

spark = SparkSession.builder.getOrCreate()

data = [("Alice", 25), ("Bob", 30), ("Charlie", 35)]
df = spark.createDataFrame(data, ["Name", "Age"])
df.show()

输出：

+-------+---+
|   Name|Age|
+-------+---+
|  Alice| 25|
|    Bob| 30|
|Charlie| 35|
+-------+---+

df = df.withColumn("Age", col("Age")+1)
df.show()

输出：

+-------+---+
|   Name|Age|
+-------+---+
|  Alice| 26|
|    Bob| 31|
|Charlie| 36|
+-------+---+

在上述代码中，withColumn()方法接受两个参数，第一个参数是要追加的列名，第二个参数是一个表达式，用于计算新列的值。在这个例子中，我们使用col()函数获取原始列"Age"的值，并将其加1，然后将结果赋给新的列"Age"。

推荐的腾讯云相关产品：腾讯云分析数据库TDSQL，它是一种高性能、高可用、高可扩展的云数据库产品，适用于大数据分析、数据仓库、BI报表等场景。产品介绍链接地址：https://cloud.tencent.com/product/tdsql

扫码

添加站长进交流群

领取专属 10元无门槛券

手把手带您无忧上云