any_value

行のグループの col の値を返します。

構文

Python

from pyspark.sql import functions as sf

sf.any_value(col, ignoreNulls=None)

パラメーター

パラメーター	Type	説明
col	pyspark.sql.Column または列名	取り組むターゲットカラム。
ignoreNulls	pyspark.sql.Column またはブール値（オプション）	最初の値が null の場合、最初の null 以外の値を検索します。

パラメーター	Type	説明
col	pyspark.sql.Column または列名	取り組むターゲットカラム。
ignoreNulls	pyspark.sql.Column またはブール値（オプション）	最初の値が null の場合、最初の null 以外の値を検索します。

戻り値

pyspark.sql.Column: 行のグループに対するcolの値。

例

Python

from pyspark.sql import functions as sf
df = spark.createDataFrame(
    [(None, 1), ("a", 2), ("a", 3), ("b", 8), ("b", 2)], ["c1", "c2"])
df.select(sf.any_value('c1'), sf.any_value('c2')).show()

Output

+-------------+-------------+
|any_value(c1)|any_value(c2)|
+-------------+-------------+
|         NULL|            1|
+-------------+-------------+

Python

df.select(sf.any_value('c1', True), sf.any_value('c2', True)).show()

Output

+-------------+-------------+
|any_value(c1)|any_value(c2)|
+-------------+-------------+
|            a|            1|
+-------------+-------------+