在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;
还没有评论,来说两句吧...