concat

Fungsi koleksi: Menggabungkan beberapa kolom input bersama-sama menjadi satu kolom. Fungsi ini berfungsi dengan string, numerik, biner, dan kolom array yang kompatibel. Mendukung Spark Connect.

Untuk fungsi Databricks SQL yang sesuai, lihat concat fungsi.

Syntax

from pyspark.databricks.sql import functions as dbf

dbf.concat(*cols)

Parameter-parameternya

Pengaturan	Tipe	Description
cols	pyspark.sql.Column atau str	Kolom target atau kolom yang akan dikerjakan.

Pengembalian Barang

pyspark.sql.Column: nilai yang digabungkan. Jenis Column tergantung pada jenis kolom input.

Examples

Contoh 1: Menggabungkan kolom string

from pyspark.databricks.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|
+------------+

Contoh 2: Menggabungkan kolom array

from pyspark.databricks.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|
+---------------+