Grup -landırma

Toplama işlevi: Listedeki belirtilen bir sütunun GROUP BY toplanıp toplanmadığını gösterir, toplanmış için 1 veya sonuç kümesinde toplanmaması için 0 döndürür.

Sözdizimi

from pyspark.sql import functions as sf

sf.grouping(col)

Parametreler

Parametre Türü Description
col pyspark.sql.Column veya str Toplanıp toplanmadiğini denetlemek için sütun.

İade

pyspark.sql.Column: toplanmış için 1, sonuç kümesinde toplanmadı için 0 döndürür.

Örnekler

Örnek 1: Küp işleminde gruplandırma durumunu denetleme

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|
+-----+--------------+--------+