【02】Flink滑动窗口统计单词个数WordCount

1、理论 滑动窗口计算 2、实践开发 Flink程序开发步骤： 获得一个执行环境 加载/创建 初始化数据 指定操作数据的 transaction 算子 指定把计算好的数据放在哪 调用execute()触发执行程序 注意：Flink程序是延迟计算的，只有最后调用execute()方法的时候才会真正触发执行程序。 延迟计算好处：可以开发复杂的程序，Flink可以将复杂的程序转成一个Plan，将Plan

>>阅读原文<<