Flink之 group by

1、 如果使用 groupby table转换为流的时候只能用toRetractDstream val rDstream: DataStream[(Boolean, (String, Long))] = table.toRetractStream[(String,Long)] 2、 toRetractDstream 得到的第一个boolean型字段标识 true就是最新的数据,false表示过期老数据 val rDstream: DataStream[(Boolean, (String, Long))] = table.toRetractStream[(String,Long)]