请问在flink sql-client中进行做group by 聚合值统计的时候，流式查询时是怎么计

在 flink sql-client 中进行 group by 聚合值统计时，流式查询时是通过窗口函数和聚合函数来计算的。具体来说，每次查询时，会对流式数据进行分组，并对每个分组内的数据应用聚合函数，从而得到每个分组的聚合结果。在这个过程中，系统并不会把所有历史明细数据都聚合一次，而是只对当前窗口内的数据进行聚合计算，从而提高查询效率。
例如，假设有一个流式数据，包含了用户ID、商品ID和购买时间等字段。如果要对每个用户的购买总数进行统计，可以使用以下 SQL 语句：

SELECT user_id, SUM(quantity) as total_buys
FROM orders
GROUP BY user_id

在这个语句中，GROUP BY 子句指定了对用户ID进行分组，SUM(quantity) 函数指定了对每个分组内的购买数量进行聚合计算。在查询时，系统会对每个用户的购买数量进行累加，并输出每个用户的购买总数。