pyspark.sql.functions.concat¶
-
pyspark.sql.functions。concat( *關口:ColumnOrName )→pyspark.sql.column.Column¶ -
連接多個輸入列成一個列。函數使用字符串、二進製和兼容數組列。
例子
> > >df=火花。createDataFrame(((“abcd”,“123”)),(“年代”,' d '])> > >df。選擇(concat(df。年代,df。d)。別名(“年代”))。收集()(行(s = ' abcd123 '))
> > >df=火花。createDataFrame((((1,2),(3,4),(5]),([1,2),沒有一個,(3])),(“一個”,“b”,“c”])> > >df。選擇(concat(df。一個,df。b,df。c)。別名(“加勒比海盜”))。收集()[行(arr =[1、2、3、4、5))、行(arr = None)]