[發明專利]一種時間序列處理的計算流圖構建方法和裝置

有效

• 申請號: 201811382844.1
• 申請日: 2018-11-20
• 公開（公告）號: CN109508412B
• 公開（公告）日: 2019-12-20
• 發明（設計）人: 李家軍;江樹浩;龔施俊;鄢貴海
• 申請（專利權）人: 中科馭數(北京)科技有限公司
• 主分類號: G06F16/901
• 分類號: G06F16/901
• 代理公司: 11612 北京金咨知識產權代理有限公司
• 代理人: 宋教花

1.一種時間序列處理的計算流圖構建方法，其特征在于，所述方法包括：

獲取待處理的時間序列處理算法；

將所述待處理的時間序列處理算法拆分為多個計算表達式；

為所述多個計算表達式分別構造計算流圖，以得到多個計算流圖；

將所述多個計算流圖進行合并，得到所述待處理的時間序列處理算法對應的流圖模型；

其中：

為所述多個計算表達式分別構造計算流圖，以得到多個計算流圖，包括：

將所述多個計算表達式放入表達式池中；

從所述表達式池中采用無放回方式隨機取出一個計算表達式，以構造相應的計算流圖；

將所述多個計算流圖進行合并，包括：

將為從所述表達式池中取出的第一個計算表達式所構造的計算流圖作為初始計算流圖；

重復以下步驟直至所述表達式池中的所有計算表達池為空：

將為從所述表達式池中取出的下一個計算表達式所構造的計算流圖作為中間計算流圖；

將所述中間計算流圖合并至所述初始計算流圖中；

將合并后所得到的計算流圖，作為初始計算流圖。

2.根據權利要求1所述的方法，其特征在于，將所述待處理的時間序列處理算法拆分為多個計算表達式，包括：

對所述待處理的時間序列處理算法進行拆分，得到輸入數據、中間數據和輸出數據；

對所述輸入數據、中間數據和輸出數據進行數據依賴分析，得到所述計算表達式。

3.根據權利要求1所述的方法，其特征在于，為所述多個計算表達式分別構造計算流圖，包括：

將當前的計算表達式的輸入時間序列作為輸入節點；

將當前的計算表達式的輸出時間序列作為輸出節點；

將輸入節點到輸出節點的連線作為有向邊，其中，所述有向邊用于表征當前的計算表達式對應的時間序列處理函數；

以所述輸入節點、所述輸出節點和所述有向邊，作為當前計算表達式的計算流圖。

4.根據權利要求1所述的方法，其特征在于，將所述中間計算流圖合并至所述初始計算流圖中，包括：

確定所述中間計算流圖與所述初始計算流圖之間是否存在相同的節點；

在存在相同的節點的情況下，刪除中間計算流圖中該相同的節點；

將刪除了該相同的節點后的中間計算流圖，合并至所述初始計算流圖中。

5.一種時間序列處理的計算流圖構建裝置，其特征在于，包括：

獲取模塊，用于獲取待處理的時間序列處理算法；

拆分模塊，用于將所述待處理的時間序列處理算法拆分為多個計算表達式；

構建模塊，用于為所述多個計算表達式分別構造計算流圖，以得到多個計算流圖；

合并模塊，用于將所述多個計算流圖進行合并，得到所述待處理的時間序列處理算法對應的流圖模型；

其中：

所述構建模塊包括：

第一生成單元，用于將當前的計算表達式的輸入時間序列作為輸入節點；

第二生成單元，用于將當前的計算表達式的輸出時間序列作為輸出節點；

第三生成單元，用于將輸入節點到輸出節點的連線作為有向邊，其中，所述有向邊用于表征當前的計算表達式對應的時間序列處理函數；

第四生成單元，用于以所述輸入節點、所述輸出節點和所述有向邊，作為當前計算表達式的計算流圖；

所述合并模塊，具體用于將為從所述表達式池中取出的第一個計算表達式所構造的計算流圖作為初始計算流圖；重復以下步驟直至所述表達式池中的所有計算表達池為空：將為從所述表達式池中取出的下一個計算表達式所構造的計算流圖作為中間計算流圖；將所述中間計算流圖合并至所述初始計算流圖中；將合并后所得到的計算流圖，作為初始計算流圖。

6.一種終端設備中，包括處理器以及用于存儲處理器可執行指令的存儲器，所述處理器執行所述指令時實現權利要求1至4中任一項所述方法的步驟。

7.一種計算機可讀存儲介質，其上存儲有計算機指令，所述指令被執行時實現權利要求1至4中任一項所述方法的步驟。