Flink笔记(二十二):Flink 之 KeyedState 的使用

场景: 不使用 Flink 提供的 sum() 方法,使用 KeyedState 完成对单词分组求和计算操作。 代码: /** * TODO 不使用 Flink 提供的sum()方法,对单词进行分组求和计算。 * * @author liuzebiao * @Date 2020-2-17 11:42 */ public class KeyedStateDemo { public static void main(String[] args) throws Exception { //1.创建一个 flink steam 程序的执行环境