pyspark.sql.functions.zip_with¶
-
pyspark.sql.functions。
zip_with
( 左:ColumnOrName,正確的:ColumnOrName,f:可調用的((pyspark.sql.column.Column,pyspark.sql.column.Column],pyspark.sql.column.Column] )→pyspark.sql.column.Column¶ -
合並兩個數組,element-wise,到一個數組中使用一個函數。如果一個數組是短,null是附加在比賽時間越長數組的長度,在應用功能。
- 參數
- 返回
例子
> > >df=火花。createDataFrame(((1,(1,3,5,8),(0,2,4,6])),(“id”,“x”,“y”))> > >df。選擇(zip_with(“x”,“y”,λx,y:x* *y)。別名(“權力”))。顯示(截斷=假)+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +權力| |+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +| | (1.0,9.0,625.0,262144.0)+ - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - +
> > >df=火花。createDataFrame(((1,(“foo”,“酒吧”),(1,2,3])),(“id”,“x”,“y”))> > >df。選擇(zip_with(“x”,“y”,λx,y:concat_ws(“_”,x,y))。別名(“xs_ys”))。顯示()+ - - - - - - - - - - - - - - - - - - +| xs_ys |+ - - - - - - - - - - - - - - - - - - +| | foo_1 bar_2 3+ - - - - - - - - - - - - - - - - - - +