Apache Flink是由Apache软件基金会开发的开源流处理框架,其核心是用Java和Scala编写的分布式流数据流引擎。Flink以数据并行和流水线方式执行任意流数据程序,Flink的流水线运行时系统可以执行批处理和流处理程序。此外,Flink的运行时本身也支持迭代算法的执行。
一. 代码准备 org.flink.beans.SensorReading org.example.SourceT...[作者空间]
笔者激活版本为IntelliJ IDEA 2018.2.3 旗舰版。当然,如果你的版本和我的不一样,也可以参考尝试...[作者空间]