Hinweis
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, sich anzumelden oder das Verzeichnis zu wechseln.
Für den Zugriff auf diese Seite ist eine Autorisierung erforderlich. Sie können versuchen, das Verzeichnis zu wechseln.
Aggregat für den gesamten DataFrame ohne Gruppen (Kurzform für df.groupBy().agg()).
Syntax
agg(*exprs: Union[Column, Dict[str, str]])
Parameter
| Parameter | Typ | Beschreibung |
|---|---|---|
exprs |
Spalte oder Diktat von Schlüssel- und Wertzeichenfolgen | Spalten oder Ausdrücke zum Aggregieren von DataFrame nach. |
Rückkehr
DataFrame: Aggregiertes DataFrame.
Beispiele
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|
# +--------+