pyspark.sql.functions.array_join ¶

pyspark.sql.functions. array_join ( col : ColumnOrName , delimiter : str , null_replacement : Optional [ str ] = None ) → pyspark.sql.column.Column [source] ¶

将列中的元素使用分隔符连接起来。如果设置了空值替换，则空值将被替换，否则它们将被忽略。

新增于版本 2.4.0。

在版本 3.4.0 中更改: 支持 Spark Connect。

Parameters

col Column or str: 目标列以进行操作。
delimiter str: 用于连接元素的分隔符
null_replacement str, optional: 如果设置，则空值将被此值替换

Returns

Column: 字符串类型的一列。连接的值。

示例

           >>> df = spark.createDataFrame([(["a", "b", "c"],), (["a", None],)], ['data'])
>>> df.select(array_join(df.data, ",").alias("joined")).collect()
[Row(joined='a,b,c'), Row(joined='a')]
>>> df.select(array_join(df.data, ",", "NULL").alias("joined")).collect()
[Row(joined='a,b,c'), Row(joined='a,NULL')]

          

pyspark.sql.functions.arrays_overlap

pyspark.sql.functions.create_map