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)]