pyflink.dataframe.dataframe.DataFrame.agg# DataFrame.agg(*aggs: Expression) → DataFrame[source]# Apply aggregation expressions to the entire DataFrame. Parameters: *aggs – Aggregation expressions. Returns: A new DataFrame with aggregation results.
