Flink应用开发系列（四十七）Table SQL开发之group by

在Flink的table sql里面我们还可以使用分组函数进行查询，这里的分组和sql是一样的，主要是group by函数。常用的group by函数查询语法是：

select ${字段},count(*) from table group by ${字段}

例如我们这里的查询结果:

然后我们还可以在sql-client上进行演示下：

首先我们创建一张表：

CREATE TABLE tmp_orders( order_number BIGINT, price DECIMAL(32,2), buyer ROW<first_name STRING, last_name STRING>, order_time TIMESTAMP(3)) WITH ( 'connector' = 'datagen', 'rows-per-second' = '1', 'number-of-rows' = '50' );

这里使用datagen来自动生成数据，然后我们使用下面的查询语句进行查询即可：

SELECT order_number,count(*) as total FROM tmp_orders group by order_number;