그룹이 없는 전체 DataFrame에 대해 집계합니다(약식 df.groupBy().agg()).
문법
agg(*exprs: Union[Column, Dict[str, str]])
매개 변수
| 매개 변수 | 유형 | 설명 |
|---|---|---|
exprs |
키 및 값 문자열의 열 또는 받아쓰기 | DataFrame을 집계할 열 또는 식입니다. |
Returns
DataFrame: 집계된 데이터 프레임입니다.
예제
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|
# +--------+