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