Not
Bu sayfaya erişim yetkilendirme gerektiriyor. Oturum açmayı veya dizinleri değiştirmeyi deneyebilirsiniz.
Bu sayfaya erişim yetkilendirme gerektiriyor. Dizinleri değiştirmeyi deneyebilirsiniz.
Toplama işlevi: Null olmayan giriş değerlerini sınırlayıcıyla ayırarak birleştirmeyi döndürür. diğer adı.listagg
Sözdizimi
from pyspark.sql import functions as sf
sf.string_agg(col, delimiter=None)
Parametreler
| Parametre | Türü | Description |
|---|---|---|
col |
pyspark.sql.Column veya str |
Hesap için hedef sütun. |
delimiter |
pyspark.sql.Column, str veya bayt, isteğe bağlı |
Değerleri ayırmak için sınırlayıcı. Varsayılan değer Yok değeridir. |
İade
pyspark.sql.Column: hesaplanan sonuçlar için sütun.
Örnekler
Örnek 1: string_agg işlevini kullanma
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|
+-------------------------+
Örnek 2: sınırlayıcı ile string_agg işlevi kullanma
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|
+-----------------------+
Örnek 3: İkili sütun ve sınırlayıcı ile string_agg işlevi kullanma
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]|
+------------------------+