サイズ

コレクション関数: 列に格納されている配列またはマップの長さを返します。Spark Connect をサポートします。

対応する Databricks SQL 関数については、 size関数を参照してください。

構文

Python

from pyspark.sql import functions as dbf

dbf.size(col=<col>)

パラメーター

パラメーター	Type	説明
col	pyspark.sql.Column または str	列または式の名前。

パラメーター	Type	説明
col	pyspark.sql.Column または str	列または式の名前。

戻り値

pyspark.sql.Column: 配列/マップの長さ。

例

Python

from pyspark.sql import functions as dbf
df = spark.createDataFrame([([1, 2, 3],),([1],),([],)], ['data'])
df.select(dbf.size(df.data)).collect()

Output

[Row(size(data)=3), Row(size(data)=1), Row(size(data)=0)]