我如何添加一個新的列火花DataFrame(使用PySpark) ?

[saipujari_spark]

我們可以添加一個新的列使用withColumn()方法的數據幀,像下麵

從pyspark.sql。功能導入點燃df = sqlContext。createDataFrame ([(1,“a”), (2 b)], (c1, c2)) df_new_col = df。withColumn (“c3”,亮了(0))df_new_col.show ()