Flink是壹個框架和分布式處理引擎,用於對無限制和有限制的數據留進行有狀態的計算。Flink被設計為可在所有常見的集群環境中運行,以內存速度和任何規模執行計算。
任何類型的數據都是作為事件流產生的。信用卡交易,傳感器測量,機器日誌或網站移動應用程序上的用戶交互,所有這些數據均作為流生成。
Flink擅長處理無邊界和有界的數據集。對事件和狀態的精確控制使Flink的運行時能夠在無限制的流上運行任何類型的應用程序。有界流由專門為固定大小的數據集設計的算法和數據結構在內部進行處理,從而產生出色的性能。
隨部署應用程序:
Flink是壹個分布式系統,需要計算資源才能執行應用程序。Flink與所有常見的集權資源管理器(如Hadoop YARN,Mesos和Kubernetes)集成,但也可以設置為作為獨立集群運行。
Flink旨在與前面列出的每個資源管理器兼容。這是通過特定於資源管理器的部署模式實現的,該模式允許Flink慣用方式與每個資源管理器進行交互。
部署Flink應用程序時,Flink會根據應用程序配置的並行性自動識別所需的資源,並向資源管理器請求它們。如果發生故障,Flink會通過請求新資源來替換發生故障的容器。提交或控制應用程序的所有通信均通過REST調用進行。簡化了Flink在許多環境中的集成。