Notitie
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen u aan te melden of de directory te wijzigen.
Voor toegang tot deze pagina is autorisatie vereist. U kunt proberen de mappen te wijzigen.
Aggregeren op het hele DataFrame zonder groepen (afkorting voor df.groupBy().agg()).
Syntaxis
agg(*exprs: Union[Column, Dict[str, str]])
Parameterwaarden
| Kenmerk | Typ | Beschrijving |
|---|---|---|
exprs |
Kolom of dicteren van sleutel- en waardetekenreeksen | Kolommen of expressies om DataFrame samen te voegen op. |
Retouren
DataFrame: Geaggregeerd DataFrame.
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|
# +--------+