文字列_agg

集計関数: 区切り文字で区切られた null 以外の入力値の連結を返します。listaggのエイリアス。

構文

Python

from pyspark.sql import functions as sf

sf.string_agg(col, delimiter=None)

パラメーター

パラメーター	Type	説明
col	pyspark.sql.Column または文字列	ターゲットカラムをコンピュートに。
delimiter	pyspark.sql.Column、strまたはbytes、オプション	値を区切る区切り文字。デフォルト値は「なし」です。

戻り値

pyspark.sql.Column: コンピュート結果の列。

例

例1 : string_agg関数の使用

Python

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

Output

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

例2 : 区切り文字付きstring_agg関数の使用

Python

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

Output

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

例3 : バイナリ列と区切り文字でstring_agg関数を使用する

Python

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()

Output

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