pyspark.sql.DataFrame.withColumns¶
-
DataFrame。withColumns( *colsMap:Dict(str,pyspark.sql.column.Column] )→pyspark.sql.dataframe.DataFrame¶ -
返回一個新的
DataFrame通過添加多個列或替換現有的列有相同的名字。colsMap列名的地圖和列,列必須參考這個數據集提供的屬性。這是一個錯誤添加列引用一些數據集。
支持多個列添加補充道
- 參數
-
- colsMap dict
-
列名的dict和
列。目前,隻支持單一的地圖。
例子
> > >df。withColumns({“age2”:df。年齡+2,“age3”:df。年齡+3})。收集()行(年齡= 2,name =“愛麗絲”,age2 = 4, age3 = 5)、行(= 5歲name =“鮑勃”,age2 = 7, age3 = 8))