Flink面试手册 - 进阶篇

一、Flink是如何支持批流一体的?  本道面试题考察的其实就是一句话:Flink的开发者认为批处理是流处理的一种特殊情况。批处理是有限的流处理。Flink 使用一个引擎支持了DataSet API 和 DataStream API。 二、Flink是如何做到高效的数据交换的?  在一个Flink Job中,数据需要在不同的task中进行交换,整个数据交换是有 TaskManager 负责的,Ta
相关文章
相关标签/搜索