本章主要实现一个Flink开发的入门程序——词频统计WordCount。通过批处理和流处理两种不同模式的实现,可以对Flink的API风格和编程方式有所熟悉,并且更加深刻地理解批处理和流处理的不同。另外,通过读取有界数据(文件)和无界数据(socket文本流)进行流处理比较,我们也可以更加直观地体会到Flink流处理的方式和特点。
这是我们学习Flink“长征路上”的第一步,是后续学习的基础。有了这番初体验,想必大家会发现Flink提供了非常易用的API,基于它进行开发并不是难事。之后我们会逐步深入展开,为大家打开Flink神奇世界的大门。