[發明專利]一種查詢調度方法

有效

• 申請號: 201810193524.5
• 申請日: 2018-03-09
• 公開（公告）號: CN108595254B
• 公開（公告）日: 2022-02-22
• 發明（設計）人: 不公告發明人
• 申請（專利權）人: 北京永洪商智科技有限公司
• 主分類號: G06F9/48
• 分類號: G06F9/48;G06F9/50
• 代理公司: 暫無信息
• 代理人: 暫無信息

1.一種查詢調度方法，其特征在于，包括以下步驟：

接收查詢任務；

判斷查詢任務中的數據來源于數據庫還是數據集市；根據判斷結果，針對數據庫查詢或數據集市查詢進行執行代價的估計；

在判斷數據來源于數據庫時，并在數據庫具有執行代價估計的功能時，獲取數據庫的估計結果，并判斷查詢任務是否有歷史記錄；在有歷史記錄的情況下，計算基于歷史記錄的估計值，利用基于歷史記錄的估計值結合權重修正數據庫的估計結果；在數據庫不提供執行代價估計的功能時，采用歷史查詢記錄對查詢任務進行估計；

當查詢任務所涉及的數據來自數據集市時，執行代價估計方法為將查詢任務分解為基本查詢任務，再基于預先設置的基本運算，估計各個基本查詢任務的執行代價，通過匯總計算獲得涉及數據集市的查詢任務的總體執行代價；

在估計出來自數據集市的查詢任務的執行代價后，判斷查詢任務是否有歷史記錄；在有歷史記錄的情況下，計算基于歷史記錄的估計值，利用上述估計值結合權重修正估計結果；

根據執行代價估計的結果，將查詢任務調度到相應優先級的執行隊列中。

2.根據權利要求1所述的查詢調度方法，其特征在于，在數據庫不提供執行代價估計的功能時，所述采用歷史查詢記錄對查詢任務進行執行代價估計，具體是采用指數平滑算法進行估計。

3.根據權利要求1所述的查詢調度方法，其特征在于，所述

在沒有歷史記錄的情況下，采用缺省值修正數據庫的估計結果。

4.根據權利要求1所述的查詢調度方法，其特征在于，在查詢任務所涉及的數據來自數據集市時，當查詢任務所涉及的數據分布在不同的節點上，則取各節點上估計結果的最大值。

5.根據權利要求1所述的查詢調度方法，其特征在于，所述數據集市為Hadoop數據集市時，僅考慮Map任務的執行代價。

6.根據權利要求5所述的查詢調度方法，其特征在于，Map任務的執行代價估計中，執行代價估計具體方法為：設置基本運算，包括數值比大小的代價compCpuCost(type)、數值類型相乘的代價productCpuCost、數值類型相加addCpuCost、維度列所形成的分組個數grpCnt、集市數據的總列數n；基于上述基本運算設置，估計過濾運算的執行代價為n*compCpuCost(type)；將聚合運算劃分為原子聚合運算和組合聚合運算；基于上述基本運算設置，原子聚合運算執行代價估計中，平方和SumSQTotal的執行代價為n*productCpuCost，計數器CountAllTotal的執行代價為n*1，總和SumTotal的執行代價為(n-grpCnt)*addCpuCost(type)；基于上述基本運算設置，組合聚合運算中，方差VarianceTotal的執行代價為SumSQTotal+CountAllTotal+SumTotal，平均值AvgTotal的執行代價為SumTotal+CountAllTotal。

7.根據權利要求6所述的查詢調度方法，其特征在于，經過所述基本運算設置和執行代價估計后，將所有代價匯總計算出一Map節點查詢的總體代價，設置查詢相關Map節點的執行代價估計的最大值作為查詢任務的執行代價估計結果。

8.根據權利要求1～7中任一所述的查詢調度方法，其特征在于，根據預先設置的閾值，將查詢任務調度到相應優先級的隊列中。

9.根據權利要求8所述的查詢調度方法，其特征在于，根據查詢任務的數量和系統壓力，動態分配不同優先級執行隊列的系統資源；和/或根據系統時間，動態調整不同優先級執行隊列的系統資源。