最近发现Flink后面将放弃所有的ScalaAPI,专注于Java,因为之前学的时候都是用Scala学的,趁这个机会也正好把Flink的内容复习一遍,Flink系列参考的主要文章都是尚硅谷的学习资料~
ApacheFlink是一个框架和分布式处理引擎,用于对无界和有界数据流进行有状态的计算。
什么是有状态的流处理?
处理数据的目标是:低延迟、高吞吐、结果的准确性和良好的容错性。
核心区别:Flink实现的是纯流处理,Spark Streaming以微批处理近似实现流处理。
Flink项目的pom依赖 欢迎关注公众号~
WordCount Demo 欢迎关注公众号~
京公网安备 11010502049817号