Catatan
Akses ke halaman ini memerlukan otorisasi. Anda dapat mencoba masuk atau mengubah direktori.
Akses ke halaman ini memerlukan otorisasi. Anda dapat mencoba mengubah direktori.
Agregat pada seluruh DataFrame tanpa grup (singkatan untuk df.groupBy().agg()).
Sintaksis
agg(*exprs: Union[Column, Dict[str, str]])
Parameter-parameternya
| Parameter | Tipe | Deskripsi |
|---|---|---|
exprs |
Kolom atau dict string kunci dan nilai | Kolom atau ekspresi untuk mengagregasi DataFrame dengan. |
Pengembalian Barang
DataFrame: DataFrame agregat.
Examples
from pyspark.sql import functions as sf
df = spark.createDataFrame([(2, "Alice"), (5, "Bob")], schema=["age", "name"])
df.agg({"age": "max"}).show()
# +--------+
# |max(age)|
# +--------+
# | 5|
# +--------+
df.agg(sf.min(df.age)).show()
# +--------+
# |min(age)|
# +--------+
# | 2|
# +--------+