Flink数据处理流程 通过前面的文章我们大概了解了实时流处理框架，这篇文章开始我们将详细来学习下Flink的使用。Flink为开发流式/批处理应用程序提供了不同级别的抽象。 而这几个抽象的模块中DataStream API用于处理实时流处理，DataSetAPI用于离线批处理。 入门Flink API 后面我们都选择使用Scala来完成Flink程序的编写，当然你也可以选择Java或者Python。Scala DataSet API的所有核心类都在包org...