Flink分组统计数据量问题

Question

使用Flink 处理一个csv文件，需要统计文件中男女个多少人，我使用如下代码：

csv_per.keyBy("sex") .sum("count") .print();

输出结果如下：

我希望只输出
1> Count{key='男', count=9}
6> Count{key='女', count=8}
两条数据，怎么弄？

Answer 1

csv_per.keyBy("sex")
    .countWindowAll(16) // 设置一个16个元素的全局计数窗口
    .sum("count")
    .print();