Nota
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare ad accedere o modificare le directory.
L'accesso a questa pagina richiede l'autorizzazione. È possibile provare a modificare le directory.
Funzione di aggregazione: restituisce la concatenazione di valori di input non Null, separati dal delimitatore. Alias di listagg.
Sintassi
from pyspark.sql import functions as sf
sf.string_agg(col, delimiter=None)
Parametri
| Parametro | TIPO | Description |
|---|---|---|
col |
pyspark.sql.Column o str |
Colonna di destinazione su cui eseguire il calcolo. |
delimiter |
pyspark.sql.Column, str o byte, facoltativo |
Delimitatore per separare i valori. Il valore predefinito è None. |
Restituzioni
pyspark.sql.Column: colonna per i risultati calcolati.
Esempi
Esempio 1: Uso della funzione string_agg
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|
+-------------------------+
Esempio 2: Uso della funzione string_agg con un delimitatore
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|
+-----------------------+
Esempio 3: Uso della funzione string_agg con una colonna binaria e un delimitatore
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]|
+------------------------+