string_agg

Statistische functie: retourneert de samenvoeging van niet-null-invoerwaarden, gescheiden door het scheidingsteken. Een alias van listagg.

Syntaxis

from pyspark.sql import functions as sf

sf.string_agg(col, delimiter=None)

Parameterwaarden

Kenmerk	Typologie	Description
col	pyspark.sql.Column of str	Doelkolom waarop moet worden berekend.
delimiter	pyspark.sql.Column, str of bytes, optioneel	Het scheidingsteken om de waarden te scheiden. De standaardwaarde is Geen.

Retouren

pyspark.sql.Column: de kolom voor berekende resultaten.

Voorbeelden

Voorbeeld 1: de functie string_agg gebruiken

from pyspark.sql import functions as sf
df = spark.createDataFrame([('a',), ('b',), (None,), ('c',)], ['strings'])
df.select(sf.string_agg('strings')).show()

+-------------------------+
|string_agg(strings, NULL)|
+-------------------------+
|                      abc|
+-------------------------+

Voorbeeld 2: string_agg functie gebruiken met een scheidingsteken

from pyspark.sql import functions as sf
df = spark.createDataFrame([('a',), ('b',), (None,), ('c',)], ['strings'])
df.select(sf.string_agg('strings', ', ')).show()

+-----------------------+
|string_agg(strings, , )|
+-----------------------+
|                a, b, c|
+-----------------------+

Voorbeeld 3: de functie string_agg gebruiken met een binaire kolom en scheidingsteken

from pyspark.sql import functions as sf
df = spark.createDataFrame([(b'\x01',), (b'\x02',), (None,), (b'\x03',)], ['bytes'])
df.select(sf.string_agg('bytes', b'\x42')).show()

+------------------------+
|string_agg(bytes, X'42')|
+------------------------+
|        [01 42 02 42 03]|
+------------------------+