IP屬地：新疆
-
Flink端到端一致性調(diào)研目錄 一、一致性定義 Flink通過插入barrier將流分為邏輯上的批，用來保存狀態(tài)。因此一個(gè)checkpointid可以理解為一批數(shù)據(jù)的狀態(tài)...
-
KafkaProducer011
For each checkpoint we create new FlinkKafkaProducer so that new transac...
-
Flink Local state VS External StateState Backend Support local state Local state backends maintain all stat...
-
確定性流處理總結(jié)StreamScope和flamestream實(shí)現(xiàn)了確定性流處理。 1.實(shí)現(xiàn)思想 這兩篇論文中都指出需要實(shí)現(xiàn)確定性的處理，需要保證 確定的執(zhí)行邏...
-
Flamestream簡單介紹1. 核心思想 通過把狀態(tài)變成流的一部分，引入循環(huán)圖，使得上一個(gè)item的狀態(tài)可以作為下一個(gè)item的輸入，使得有狀態(tài)算子變成無狀態(tài)算子。 be...
-
