pyflink.dataframe.GroupedDataFrame

class GroupedDataFrame(df: pyflink.dataframe.dataframe.DataFrame, group_keys: List[pyflink.table.expression.Expression])

A grouped DataFrame for aggregation operations.

Methods

agg(*aggs, **named_aggs)

Apply aggregation expressions.