-
API層:
主要實現(xiàn)了面向無界Stream的流處理和面向Batch的批處理API,其中面向流處理對應(yīng)DataStream API,面向批處理對應(yīng)的DataSet API。
查看全部 -
Runtime層:
提供了支持Flink計算的全部核心實現(xiàn),比如:支持分布式Stream處理、JobGraph到ExecutionGraph的映射、調(diào)度等等,為上層API層提供基礎(chǔ)服務(wù)。
查看全部 -
Deployment層
主要涉及Flink部署模式:
1、本地
2、集群(Standalone、YARN)
3、云(GCE/EC2)
查看全部 -
Flink特點:
Flink是完全支持流處理(作為流處理看待時,輸入數(shù)據(jù)流是無界的)。
批處理被作為一種特殊的流處理,只是它的輸入數(shù)據(jù)流被定義為有界的。
查看全部 -
Flink定義:
Apache Flink是一個面向分布式數(shù)據(jù)流處理和批量數(shù)據(jù)處理的開源計算平臺,提供支持流處理和批處理兩種類型。
查看全部 -
flink并行度查看全部
-
flink代碼查看全部
-
處理模型與延遲
數(shù)據(jù)處理保證
查看全部 -
架構(gòu)和容錯比較
?flink基于Chandy-Lamport checkpoint分布式快照模型
spark streaming是基于WAL及RDD血統(tǒng)機制,高容錯
storm Records ACK
查看全部 -
flink自身優(yōu)勢
查看全部 -
好查看全部
-
啥事窗口操作查看全部
-
層查看全部
-
DataStream API
查看全部 -
DataStream API
查看全部
舉報