Flink 号称是下一代实时计算引擎,相比于 Storm 和 Spark,Flink 的确是后起之秀 ,在2015 年1月才成为 Apache 的顶级开源醒目,但发展非常迅速,目前已经得到了很多重量级公司的支持,比如 Netflix,Uber 和 阿里巴巴。Flink 对Stateful(有状态,有状态意味着在计算过程中维持一段时间中间结算结果)的计算支持比较好,通过检查点机制可以自动对其进行容错管理,能够快速恢复,同时保证结果的正确。Flink 还提供多种灵活的窗口定义形式,比如时间窗口、技术窗口、回话窗口等,可以轻松支持复杂的应用场景。另外,Flink 也是一个高吞吐量低延迟的框架能运行在数千节点的大规模集群上,通过 Back Pressure(反压)机制能自动平台节点之间的负载,按照官方文档的介绍,对于同样一个简单的计数任务,Flink 比 Storm 高了不止一个数量级,如图:

下面运行一个简单的例子:

TODO

results matching ""

    No results matching ""