[發(fā)明專利]一種賬號打通的計算方法及系統(tǒng)

在審

• 申請?zhí)枺?/td>: 202011433284.5
• 申請日: 2020-12-10
• 公開（公告）號: CN112463065A
• 公開（公告）日: 2021-03-09
• 發(fā)明（設(shè)計）人: 顧廣澤;劉俊
• 申請（專利權(quán)）人: 恩億科（北京）數(shù)據(jù)科技有限公司
• 主分類號: G06F3/06
• 分類號: G06F3/06;G06F16/182
• 代理公司: 青島清泰聯(lián)信知識產(chǎn)權(quán)代理有限公司 37256
• 代理人: 李紅巖

1.一種賬號打通的計算方法，其特征在于，所述計算方法包括：

數(shù)據(jù)提供步驟：上游提供外部數(shù)據(jù)；

預(yù)處理步驟：對所述外部數(shù)據(jù)進行預(yù)處理；

迭代步驟：預(yù)處理后的所述外部數(shù)據(jù)的Vertex的Super ID進行迭代；

選舉步驟：根據(jù)選舉規(guī)則，選舉出迭代中所述Vertex的Super ID；

判斷步驟:當(dāng)所述Vertex的所述Super ID都達到收斂狀態(tài)時，達到收斂狀態(tài)的Vertex的Super ID存儲到HDFS存儲中。

2.根據(jù)權(quán)利要求1所述的賬號打通的計算方法，其特征在于，所述數(shù)據(jù)提供步驟包括，上游提供外部數(shù)據(jù)，所述外部數(shù)據(jù)包括IDPairs對、解綁IDPairs對、IDType優(yōu)先級、黑名單。

3.根據(jù)權(quán)利要求2所述的賬號打通的計算方法，其特征在于，所述預(yù)處理步驟包括，對所述IDPairs對進行預(yù)處理，所述預(yù)處理包括過濾黑名單ID、對所述解綁IDPairs對的信息進行標(biāo)記及將所述IDPairs對轉(zhuǎn)換成數(shù)據(jù)結(jié)構(gòu)。

4.根據(jù)權(quán)利要求1所述的賬號打通的計算方法，其特征在于，所述迭代步驟包括，將所述外部數(shù)據(jù)的所述Vertex作為計算的中心，找出Edge中與其相連的點，并將所述點的SuperID作為消息發(fā)給所述Vertex，迭代器迭代所述Vertex的所述Super ID直到所述Super ID不再更新為止。

5.根據(jù)權(quán)利要求4所述的賬號打通的計算方法，其特征在于，所述選舉步驟包括，以所述Vertex的所述Super ID作為數(shù)據(jù)輸入，根據(jù)來源消息的IDType優(yōu)先級及與所述Vertex相連的Edge時間作為所述選舉規(guī)則，選舉出迭代中所述Vertex的Super ID。

6.根據(jù)權(quán)利要求1所述的賬號打通的計算方法，其特征在于，所述判斷步驟包括，當(dāng)所述Vertex的所述Super ID都達到收斂狀態(tài)時，達到收斂狀態(tài)的Vertex的Super ID存儲到HDFS存儲中。

7.一種賬號打通的計算系統(tǒng)，其特征在于，適用于上述權(quán)利要求1-6所述的一種賬號打通的計算方法，包括：

數(shù)據(jù)提供單元：上游提供外部數(shù)據(jù)；

預(yù)處理單元：對所述外部數(shù)據(jù)進行預(yù)處理；

迭代單元：預(yù)處理后的所述外部數(shù)據(jù)的Vertex的Super ID進行迭代；

選舉單元：根據(jù)選舉規(guī)則，選舉出迭代中所述Vertex的Super ID；

判斷單元:當(dāng)所有Vertex達到收斂狀態(tài)時，達到收斂狀態(tài)的所述Vertex的Super ID存儲到HDFS存儲中。

8.根據(jù)權(quán)利要求7所述的賬號打通的計算系統(tǒng)，其特征在于，所述數(shù)據(jù)提供單元包括，上游提供外部數(shù)據(jù)，所述外部數(shù)據(jù)包括IDPairs對、解綁IDPairs對、IDType優(yōu)先級、黑名單。

9.根據(jù)權(quán)利要求8所述的賬號打通的計算系統(tǒng)，其特征在于，所述預(yù)處理單元包括，對所述IDPairs對進行預(yù)處理，所述預(yù)處理包括過濾黑名單ID、對所述解綁IDPairs對的信息進行標(biāo)記及將所述IDPair s對轉(zhuǎn)換成數(shù)據(jù)結(jié)構(gòu)。

10.根據(jù)權(quán)利要求9所述的賬號打通的計算系統(tǒng)，其特征在于，所述迭代單元包括，將所述外部數(shù)據(jù)的所述Vertex作為計算的中心，找出Edge中與其相連的點，并將所述點的SuperID作為消息發(fā)給所述Vertex，迭代器迭代所述Vertex的所述Super ID直到所述Super ID不再更新為止；所述選舉單元包括，以所述Vertex的所述Super ID作為數(shù)據(jù)輸入，根據(jù)來源消息的IDType優(yōu)先級及與所述Vertex相連的Edge時間作為所述選舉規(guī)則，選舉出迭代中所述Vertex的Super ID；所述判斷單元包括，當(dāng)所述Vertex的所述Super ID都達到收斂狀態(tài)時，達到收斂狀態(tài)的Vertex的Super ID存儲到HDFS存儲中。