pyspark.sql.functions.array_join¶
-
pyspark.sql.functions。array_join( 上校:ColumnOrName,分隔符:str,null_replacement:可選(str]=沒有一個 )→pyspark.sql.column.Column¶ -
連接的元素列使用分隔符。空值替換null_replacement如果設置,否則他們將被忽略。
例子
> > >df=火花。createDataFrame((((“一個”,“b”,“c”),),([“一個”,沒有一個),),(“數據”])> > >df。選擇(array_join(df。數據,”、“)。別名(“加入”))。收集()[行(加入= a, b, c)、行(加入= ' a '))> > >df。選擇(array_join(df。數據,”、“,“零”)。別名(“加入”))。收集()行(加入= a, b, c)、行(加入= ',零'))