seskupení

Agregační funkce: Určuje, zda je zadaný sloupec v GROUP BY seznamu agregovaný nebo ne, vrátí hodnotu 1 pro agregované nebo 0 pro neagregované v sadě výsledků.

Syntaxe

from pyspark.sql import functions as sf

sf.grouping(col)

Parametry

Parameter	Typ	Description
col	pyspark.sql.Column nebo str	Sloupec, který zkontroluje, jestli je agregovaný.

Návraty

pyspark.sql.Column: vrátí hodnotu 1 pro agregovanou hodnotu nebo hodnotu 0, která není agregována v sadě výsledků.

Examples

Příklad 1: Kontrola stavu seskupení v operaci datové krychle

from pyspark.sql import functions as sf
df = spark.createDataFrame([("Alice", 2), ("Bob", 5)], ("name", "age"))
df.cube("name").agg(sf.grouping("name"), sf.sum("age")).orderBy("name").show()

+-----+--------------+--------+
| name|grouping(name)|sum(age)|
+-----+--------------+--------+
| NULL|             1|       7|
|Alice|             0|       2|
|  Bob|             0|       5|
+-----+--------------+--------+