concat

Koleksiyon işlevi: Birden çok giriş sütununu tek bir sütunda birleştirir. işlevi dizeler, sayısal, ikili ve uyumlu dizi sütunlarıyla çalışır. Spark Connect'i destekler.

İlgili Databricks SQL fonksiyonu için bakınız concat fonksiyonu.

Sözdizimi

from pyspark.sql import functions as dbf

dbf.concat(*cols)

Parametreler

Parametre	Türü	Description
cols	pyspark.sql.Column veya str	Üzerinde çalışacak sütunu veya sütunları hedefle.

İade

pyspark.sql.Column: birleştirilmiş değerler. türü Column , giriş sütunlarının türüne bağlıdır.

Örnekler

Örnek 1: Dize sütunlarını birleştirme

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|
+------------+

Örnek 2: Dizi sütunlarını birleştirme

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|
+---------------+