![240](https://upload.jianshu.io/users/upload_avatars/18509379/d54ef898-107f-45be-9b86-c82f0cc5da48.jpg?imageMogr2/auto-orient/strip|imageView2/1/w/240/h/240)
見(jiàn)知乎文章https://zhuanlan.zhihu.com/p/617706691[https://zhuanlan.zhihu.com/p...
本文是閱讀了Etcd client v3官方代碼后后雷,結(jié)合個(gè)人理解做的一些整理唾琼,有理解不正確不到位的地方還望指正~ Etcd版本信息 代碼庫(kù):ht...
Raft是一種分布式一致性算法薯酝,相比于Paxos,它更容易理解和實(shí)現(xiàn)瞻润,效率也相當(dāng)店乐。Raft 將一致性的關(guān)鍵元素分成幾部分,如leader選舉撇寞、日...
InfluxDB 概念:InfluxDB是一種時(shí)序數(shù)據(jù)庫(kù):按時(shí)間順序?qū)懭霐?shù)據(jù)顿天,并按照一定時(shí)間策略保留數(shù)據(jù)的數(shù)據(jù)庫(kù) 1. Database: 數(shù)據(jù)...
1. 目的 為了實(shí)現(xiàn)flink任務(wù)的容災(zāi)與恢復(fù) 2. 概念以及實(shí)現(xiàn)原理 狀態(tài)state:指算子或算子并發(fā)中的狀態(tài)數(shù)據(jù),與數(shù)據(jù)流有關(guān)系蔑担,隨流入...
DataStream 1. map/flatMap MapFunction<T, O> 輸入一個(gè)元素牌废,輸出一個(gè)元素,其中包含了變換邏輯 Rich...
1. Connect DataStream有兩個(gè)connect方法: 前者是與普通DataStream連接啤握,多用于把兩個(gè)流合并鸟缕;后者是與一個(gè)Br...
DataStream上游算子向下游算子發(fā)送數(shù)據(jù)的不同方式: forward (默認(rèn)) the output elements are forwa...
定義與作用 官方定義:A Watermark tells operators that no elements with a timestamp...