pengelompokan

Fungsi agregat: menunjukkan apakah kolom tertentu dalam GROUP BY daftar dikumpulkan atau tidak, mengembalikan 1 untuk agregat atau 0 untuk tidak dikumpulkan dalam tataan hasil.

Syntax

from pyspark.sql import functions as sf

sf.grouping(col)

Parameter-parameternya

Pengaturan	Tipe	Description
col	pyspark.sql.Column atau str	Kolom untuk memeriksa apakah kolom dikumpulkan.

Pengembalian Barang

pyspark.sql.Column: mengembalikan 1 untuk agregat atau 0 untuk tidak diagregasi dalam tataan hasil.

Examples

Contoh 1: Periksa status pengelompokan dalam operasi kubus

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