前言
在很多业务场景下，我们需要对读取到的数据根据业务字段做聚合、统计甚至计算等操作，因此flink提供了基于KeyedStream 的丰富的滚动聚合算子满足多种业务场景下的聚合统计需求
下面来看看几种常用的滚动聚合算子API操作
环境准备
1、准备一个外部文件，用于程序读取
这里在工程的resources目录下，准备一个sensor.txt文件，内容如下
编码实现
需求说明，读取上述文件中的每行数据，按照第一个字段分组，求第三个字段的最大值
import com.congge.source.SensorReading;
import org.apache.flink.api.java.tuple.Tuple;
import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.datastream.KeyedStream;
import org.apache.flink.s版权声明：本文内容由互联网用户自发贡献，该文观点仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容， 请发送邮件至 举报，一经查实，本站将立刻删除。
文章由半码博客整理，本文链接：https://www.bmabk.com/index.php/post/143326.html
