Pipeline.aggregate()

Aggregate data by a given key.

Usage

Pipeline.aggregate(
    group_by,
    agg_func="sum",
)

Parameters

group_by: str

The field to group by.

agg_func: str = "sum"

Aggregation function: ‘sum’, ‘mean’, ‘count’.

Returns

dict

Aggregated results.