Oharra
Baimena behar duzu orria atzitzeko. Direktorioetan saioa has dezakezu edo haiek alda ditzakezu.
Baimena behar duzu orria atzitzeko. Direktorioak alda ditzakezu.
Agregado en toda la trama de datos sin grupos (abreviada para df.groupBy().agg()).
Sintaxis
agg(*exprs: Union[Column, Dict[str, str]])
Parámetros
| Parámetro | Tipo | Descripción |
|---|---|---|
exprs |
Columna o dict de cadenas de clave y valor | Columnas o expresiones para agregar DataFrame by. |
Devoluciones
DataFrame: DataFrame agregado.
Ejemplos
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|
# +--------+