GreenPlum數(shù)據(jù)分布機(jī)制
一、介紹
GreenPlum是Coodinator/Segment架構(gòu),集群通常由一個(gè)Coodinator節(jié)點(diǎn)和一個(gè)standby coodinator節(jié)點(diǎn)以及多個(gè)segment節(jié)點(diǎn)組成,其中數(shù)據(jù)放置在segment節(jié)點(diǎn)上。Coodinator是整個(gè)數(shù)據(jù)庫(kù)的入口,客戶(hù)端只會(huì)連接到Coodinator上并執(zhí)行相關(guān)查詢(xún)操作,Standby節(jié)點(diǎn)為Coordinator提供高可用支持,Mirror為primary的備。
數(shù)據(jù)默認(rèn)使用hash分布。
二、插入時(shí)數(shù)據(jù)是如何分布分發(fā)到哪個(gè)segment?
1、插入操作時(shí)值的由來(lái)
我們看下insert語(yǔ)句的執(zhí)行計(jì)劃:
它沒(méi)有Motion節(jié)點(diǎn),僅1個(gè)slice,即root slice。Result節(jié)點(diǎn)是將insert的值物化以構(gòu)建TupleTableSlot進(jìn)行插入。也就是先物化然后insert。
這里主要關(guān)注物化的值從哪來(lái)。Result節(jié)點(diǎn)的執(zhí)行堆棧為:
ExecInterpExpr計(jì)算物化值步驟:EEOP_CONST;EEOP_ASSIGN_TMP。也就是得到個(gè)常量值放到resultslot中。
通過(guò)gdb跟蹤每個(gè)segment進(jìn)程,可以了解到這里的常量值就是INSERT語(yǔ)句中VALUES的值。
此時(shí)就可以了解到,SQL語(yǔ)句中VALUES值是直接發(fā)送到對(duì)于的segment的。
那么,具體是如何發(fā)送的呢?
2、值的發(fā)送
發(fā)送函數(shù)由cdbdisp_dispatchX完成。我們來(lái)跟蹤這個(gè)函數(shù),看下是如何分發(fā)到指定的segment的。
了解GP原理的話,我們知道發(fā)送前需要先在master和segment之間建立一個(gè)連接,然后將執(zhí)行計(jì)劃通過(guò)這個(gè)連接發(fā)送過(guò)去。建立連接就是創(chuàng)建Gang,由函數(shù)AssignGangs完成。
最終創(chuàng)建Gang建立連接會(huì)調(diào)用函數(shù)cdbgang_createGang_async。下面我們看下這個(gè)函數(shù)是如何建立連接的。
cdbconn_doConnectStart連接時(shí),SegmentDatabaseDescriptor segdbDesc中的segment_database_info::GpSegConfigEntry存有segment的端口及IP等信息,即gp_segment_configuration系統(tǒng)表中內(nèi)容;诖诵畔,可以建立連接。
那么segdbDesc內(nèi)容從何而來(lái)?
從上述堆棧,segdbDesc是Gang中的db_descriptors[i],也就是buildGangDefinition函數(shù)生成:
SliceTable.slices[0].segments為入?yún)egments鏈表,存儲(chǔ)著執(zhí)行該slice的所有segment的content id。segdbDesc是根據(jù)content id從系統(tǒng)表gp_segment_config來(lái)獲取。
到這里可以知道,通過(guò)SliceTable中的segment鏈表得到該slice的segment的content。Insert僅一個(gè)slice,insert分發(fā)到執(zhí)行該insert的segment,content就是該segment的content id。通過(guò)該content id從gp_segment_configuration系統(tǒng)表中得到相關(guān)port、IP等信息,從而據(jù)此在master和segment之間建立連接。構(gòu)建鏈接后,insert語(yǔ)句通過(guò)此鏈接發(fā)送到對(duì)應(yīng)的segment。
那么content id又是如何與分布鍵聯(lián)系起來(lái)呢?
經(jīng)過(guò)分析,由函數(shù)DirectDispatchUpdateContentIdsForInsert來(lái)完成映射:
constvalue為分布鍵的key值,然后通過(guò)cdbhash函數(shù)通過(guò)系統(tǒng)hash函數(shù)將key值進(jìn)行hash,最終得到hashcode,該值即為content id,放到contentIds鏈表中。
三、基礎(chǔ)知識(shí)1、gp_segment_configuration
2、Gang、slice與QueryDesc之間關(guān)系
原文標(biāo)題 : GreenPlum數(shù)據(jù)分布機(jī)制

發(fā)表評(píng)論
請(qǐng)輸入評(píng)論內(nèi)容...
請(qǐng)輸入評(píng)論/評(píng)論長(zhǎng)度6~500個(gè)字
最新活動(dòng)更多
-
6月20日立即下載>> 【白皮書(shū)】精準(zhǔn)測(cè)量 安全高效——福祿克光伏行業(yè)解決方案
-
7月3日立即報(bào)名>> 【在線會(huì)議】英飛凌新一代智能照明方案賦能綠色建筑與工業(yè)互聯(lián)
-
7月22-29日立即報(bào)名>> 【線下論壇】第三屆安富利汽車(chē)生態(tài)圈峰會(huì)
-
7.30-8.1火熱報(bào)名中>> 全數(shù)會(huì)2025(第六屆)機(jī)器人及智能工廠展
-
7月31日免費(fèi)預(yù)約>> OFweek 2025具身機(jī)器人動(dòng)力電池技術(shù)應(yīng)用大會(huì)
-
免費(fèi)參會(huì)立即報(bào)名>> 7月30日- 8月1日 2025全數(shù)會(huì)工業(yè)芯片與傳感儀表展
推薦專(zhuān)題
- 1 AI 眼鏡讓百萬(wàn) APP「集體失業(yè)」?
- 2 大廠紛紛入局,百度、阿里、字節(jié)搶奪Agent話語(yǔ)權(quán)
- 3 深度報(bào)告|中國(guó)AI產(chǎn)業(yè)正在崛起成全球力量,市場(chǎng)潛力和關(guān)鍵挑戰(zhàn)有哪些?
- 4 上海跑出80億超級(jí)獨(dú)角獸:獲上市公司戰(zhàn)投,干人形機(jī)器人
- 5 國(guó)家數(shù)據(jù)局局長(zhǎng)劉烈宏調(diào)研格創(chuàng)東智
- 6 下一代入口之戰(zhàn):大廠為何紛紛押注智能體?
- 7 百億AI芯片訂單,瘋狂傾銷(xiāo)中東?
- 8 Robotaxi新消息密集釋放,量產(chǎn)元年誰(shuí)在領(lǐng)跑?
- 9 格斗大賽出圈!人形機(jī)器人致命短板曝光:頭腦過(guò)于簡(jiǎn)單
- 10 一文看懂視覺(jué)語(yǔ)言動(dòng)作模型(VLA)及其應(yīng)用