[發明專利]一種流計算執行方法、設備及計算機可讀存儲介質

在審

• 申請號: 202010126806.0
• 申請日: 2020-02-28
• 公開（公告）號: CN111414385A
• 公開（公告）日: 2020-07-14
• 發明（設計）人: 于連宇;高鋒
• 申請（專利權）人: 聯想（北京）有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455
• 代理公司: 北京樂知新創知識產權代理事務所(普通合伙) 11734
• 代理人: 江宇

1.一種流計算執行方法，其特征在于，所述方法包括：

接收自定義的流計算算法；

從執行引擎庫中選擇與所述流計算算法匹配的執行引擎；

接收流數據；

對所述流數據進行標準化處理；

利用所述匹配的執行引擎對標準化處理后的流數據執行所述流計算算法，得到標準化執行結果。

2.根據權利要求1所述的方法，其特征在于，在接收自定義的流計算算法之后，所述方法還包括：

對所述流計算算法進行正確性驗證；

相應的，從執行引擎庫中選擇與所述流計算算法匹配的執行引擎，包括：

從執行引擎庫中選擇與正確性驗證通過后的流計算算法匹配的執行引擎。

3.根據權利要求2所述的方法，其特征在于，所述方法還包括：

對所述流計算算法進行依賴解析，得到依賴解析結果；

相應的，從執行引擎庫中選擇與所述流計算算法匹配的執行引擎，還包括：

從執行引擎庫中選擇與所述依賴解析結果匹配的依賴執行引擎。

4.根據權利要求1所述的方法，其特征在于，所述接收流數據，包括：

初始化緩沖池，所述緩沖池用于緩存待執行流計算的數據；

將接收到的流數據按流窗口更新存儲至緩沖池；

相應的，對所述流數據進行標準化處理，包括：

對更新存儲至緩沖池中的流數據進行標準化處理。

5.根據權利要求1所述的方法，其特征在于，利用所述匹配的執行引擎對標準化處理后的流數據執行所述流計算算法，包括：

分別將所述標準化處理后的流數據和流計算算法傳送至引擎執行環境；

在所述引擎執行環境中利用所述匹配的執行引擎執行所述流計算算法。

6.一種流計算執行設備，其特征在于，所述設備包括：

接收模塊，用于接收自定義的流計算算法；

選擇模塊，用于從執行引擎庫中選擇與所述流計算算法匹配的執行引擎；

所述接收模塊，還用于接收流數據；

標準化處理模塊，用于對所述流數據進行標準化處理；

執行模塊，用于利用所述匹配的執行引擎對標準化處理后的流數據執行所述流計算算法，得到標注化執行結果。

7.根據權利要求6所述的設備，其特征在于，所述設備還包括：

正確性驗證模塊，用于在通過接收模塊接收自定義的流計算算法之后，對所述流計算算法進行正確性驗證；

相應的，所述選擇模塊，還用于從執行引擎庫中選擇與正確性驗證通過后的老舊計算算法匹配的執行引擎。

8.根據權利要求7所述的設備，其特征在于，所述設備還包括：

依賴解析模塊，用于對所述流計算算法進行依賴解析，得到依賴解析結果；

相應的，所述選擇模塊，還用于從執行引擎庫中選擇與所述依賴解析結果匹配的依賴執行引擎。

9.根據權利要求6所述的設備，其特征在于，

所述接收模塊，具體用于初始化緩沖池，所述緩沖池用于緩存待執行流計算的數據；將接收到的流數據按流窗口更新存儲至緩沖池；

相應的，所述標準化處理模塊，具體用于對更新存儲至緩沖池中的流數據進行標準化處理。

10.一種計算機可讀存儲介質，其特征在于，所述存儲介質包括一組計算機可執行指令，當所述指令被執行時用于執行權利要求1至5任一項所述的流計算執行方法。