小編給大家分享一下apache flink指的是什么,希望大家閱讀完這篇文章后大所收獲,下面讓我們一起去探討吧!
Apache Flink是由Apache軟件基金會開發的開源流處理框架,其核心是用Java和Scala編寫的分布式流數據流引擎。Flink以數據并行和流水線方式執行任意流數據程序,Flink的流水線運行時系統可以執行批處理和流處理程序。此外,Flink的運行時本身也支持迭代算法的執行。
Flink提供高吞吐量、低延遲的流數據引擎以及對事件-時間處理和狀態管理的支持。Flink應用程序在發生機器故障時具有容錯能力,并且支持exactly-once語義。程序可以用Java、Scala[9]、Python[和SQL等語言編寫,并自動編譯和優化到在集群或云環境中運行的數據流程序。
Flink并不提供自己的數據存儲系統,但為Amazon Kinesis、Apache Kafka、HDFS、Apache Cassandra和ElasticSearch等系統提供了數據源和接收器。
Apache Flink的數據流編程模型在有限和無限數據集上提供單次事件(event-at-a-time)處理。在基礎層面,Flink程序由流和轉換組成。 “從概念上講,流是一種(可能永無止境的)數據流記錄,轉換是一種將一個或多個流作為輸入并因此產生一個或多個輸出流的操作”。
Apache Flink包括兩個核心API:用于有界或無界數據流的數據流API和用于有界數據集的數據集API。Flink還提供了一個表API,它是一種類似SQL的表達式語言,用于關系流和批處理,可以很容易地嵌入到Flink的數據流和數據集API中。Flink支持的最高級語言是SQL,它在語義上類似于表API,并將程序表示為SQL查詢表達式。
看完了這篇文章,相信你對apache flink指的是什么有了一定的了解,想了解更多相關知識,歡迎關注億速云行業資訊頻道,感謝各位的閱讀!
免責聲明:本站發布的內容(圖片、視頻和文字)以原創、轉載和分享為主,文章觀點不代表本網站立場,如果涉及侵權請聯系站長郵箱:is@yisu.com進行舉報,并提供相關證據,一經查實,將立刻刪除涉嫌侵權內容。