第3章　開發(fā)Flink實(shí)時數(shù)據(jù)處理程序

實(shí)時分析是當(dāng)前非常重要的一個問題。許多不同的領(lǐng)域需要實(shí)時處理數(shù)據(jù)。例如，來自物聯(lián)網(wǎng)（IoT）的應(yīng)用程序需要實(shí)時或近實(shí)時地存儲、處理和分析數(shù)據(jù)。

為了滿足對實(shí)時數(shù)據(jù)處理的需求，Apache Flink提供了一個名為DataStream API的流數(shù)據(jù)處理API，用于構(gòu)建健壯的、有狀態(tài)的流應(yīng)用程序。它提供了對狀態(tài)和時間的細(xì)粒度控制，允許實(shí)現(xiàn)高級事件驅(qū)動系統(tǒng)。

Apache Flink的流處理API（DataStream API）位于org.apache.flink.streaming.api.scala包（Scala語言）或org.apache.flink.streaming.api包（Java語言）中。