1.3 Flink的未來

Flink的理想是構建以流為核心的批流一體的計算框架，但是目前還沒有完全實現以流為核心的計算。在Flink1.9版本之前，批流是兩套體系，批處理的API是DataSet API，流計算的API是DataStream API。從Flink1.9版本開始，開啟了批流一體的進程。首先在Flink Table&SQL模塊的API和算子層面上實現了統一，在不遠的未來，DataSet API將會被廢棄，同樣DataSet的算子也會被廢棄，從而完全使用DataStream API及其算子來實現批流的統一。

隨著AI的持續發展，Flink在其1.9及以后的版本中設計了新的PyFlink，提供Python API，逐漸將AI生態融合進來，AI開發者可以充分使用Flink的分布式計算能力。在Flink1.10版本中，PyFlink還不是特別成熟，所以本書中暫不對此進行介紹，待Flink的后續版本發布之后，再詳細介紹其原理和實現。