concat

Funkce kolekce: Zřetězí více vstupních sloupců do jednoho sloupce. Funkce funguje s řetězci, číselnými, binárními a kompatibilními maticovými sloupci. Podporuje Spark Connect.

Odpovídající funkci SQL Databricks vizte funkceconcat.

Syntaxe

from pyspark.sql import functions as dbf

dbf.concat(*cols)

Parametry

Parameter	Typ	Description
cols	pyspark.sql.Column nebo str	Cílový sloupec nebo sloupce, na kterých chcete pracovat.

Návraty

pyspark.sql.Column: zřetězené hodnoty. Typ sloupce Column závisí na typu vstupních sloupců.

Examples

Příklad 1: Zřetězení sloupců řetězců

from pyspark.sql import functions as dbf
df = spark.createDataFrame([('abcd','123')], ['s', 'd'])
df.select(dbf.concat(df.s, df.d)).show()

+------------+
|concat(s, d)|
+------------+
|     abcd123|
+------------+

Příklad 2: Zřetězení sloupců pole

from pyspark.sql import functions as dbf
df = spark.createDataFrame([([1, 2], [3, 4], [5]), ([1, 2], None, [3])], ['a', 'b', 'c'])
df.select(dbf.concat(df.a, df.b, df.c)).show()

+---------------+
|concat(a, b, c)|
+---------------+
|[1, 2, 3, 4, 5]|
|           NULL|
+---------------+