LazyGroupBy.agg

LazyFrame agg(AggSpec[] specs...) @safe

Aggregates the groups per eager aggregation specifications.

Parameters

specsthe aggregations

Returns

the deferred aggregation (blocking for streaming).
LazyFrame agg(Expr[] exprs...) @safe

Ditto, from aggregate expressions: each argument is an aggregation over a direct column reference (col("v").sum(), .quantile(q), ...), optionally renamed - the rename becomes the output column name.

Parameters

exprsthe aggregate expressions

Returns

the deferred aggregation.

Throws

DataFrameException for non-aggregate arguments.