[發明專利]一種數據存儲方法、裝置、電子設備及存儲介質在審
| 申請號: | 202011490796.5 | 申請日: | 2020-12-16 |
| 公開(公告)號: | CN112486421A | 公開(公告)日: | 2021-03-12 |
| 發明(設計)人: | 宋鑫;韓朱忠 | 申請(專利權)人: | 上海達夢數據庫有限公司 |
| 主分類號: | G06F3/06 | 分類號: | G06F3/06 |
| 代理公司: | 北京品源專利代理有限公司 11332 | 代理人: | 孟金喆 |
| 地址: | 201203 上海*** | 國省代碼: | 上海;31 |
| 權利要求書: | 查看更多 | 說明書: | 查看更多 |
| 摘要: | |||
| 搜索關鍵詞: | 一種 數據 存儲 方法 裝置 電子設備 介質 | ||
本發明公開了一種數據存儲方法、裝置、電子設備及存儲介質。該方法包括:根據獲取到的左孩子節點的待存儲數據,確定所述待存儲數據對應的內存空間,所述內存空間包括一個或多個內存切片,每一內存切片對應所述待存儲數據中的子數據;將子數據存入對應的內存切片之后,觸發數據加載節點讀取對應內存切片中存入的子數據,直至所述待存儲數據全部存入對應的內存空間。本發明實施例實現了有效地提升并發效率,減少響應時間。
技術領域
本發明實施例涉及計算機技術,尤其涉及一種并行調度方法、裝置、電子設備及存儲介質。
背景技術
數據庫管理系統為充分利用多核CPU物理資源、提升查詢執行的效率,通常會支持多線程并發執行。并行查詢的框架有一種生產者-消費者模型,該模型通過將查詢計劃按照數據發送操作符以及數據接收操作符劃分,得到一個或者多個子計劃,子計劃在執行時按照依賴關系先后調度,以確保被依賴的子計劃C(即生產者)在執行完成或者第一次輸出數據之后,調度依賴于它的父層子計劃P(即消費者)。
由于在基于生產者-消費者并發調度模型框架中,對公共子計劃的處理方式通常是等待生產者子計劃調度完成,即數據存儲完成后,再調度消費者子計劃。這種方式的并發利用率不高,且響應時間較長。
發明內容
本發明提供一種數據存儲方法、裝置、電子設備及存儲介質,以實現能夠有效地提升并發效率,減少響應時間。
第一方面,本發明實施例提供了一種數據存儲方法,應用于數據存儲節點,包括:
根據獲取到的左孩子節點的待存儲數據,確定所述待存儲數據對應的內存空間,所述內存空間包括一個或多個內存切片,每一內存切片對應所述待存儲數據中的子數據;
將子數據存入對應的內存切片之后,觸發數據加載節點讀取對應內存切片中存入的子數據,直至所述待存儲數據全部存入對應的內存空間。
進一步的,所述根據獲取到的左孩子節點的待存儲數據,確定所述待存儲數據對應的內存空間,所述內存空間包括一個或多個內存切片,每一內存切片對應所述待存儲數據中的子數據,包括:
根據獲取到的所述待存儲數據的行數與內存切片行數,確定所述待存儲數據對應的內存空間中內存切片數量;
如果所述待存儲數據對應的內存空間中內存切片數量大于零,則根據所述待存儲數據對應的內存空間中內存切片數量在數據存儲節點內存結構中申請對應的內存空間。
進一步的,所述如果所述待存儲數據對應的內存空間中內存切片數量大于零,則根據所述待存儲數據對應的內存空間中內存切片數量在數據存儲節點內存中申請對應的內存空間之后,還包括:
如果所述待存儲數據申請內存空間失敗,則將數據存儲節點中內存結構中的數據存入磁盤,同時將數據存儲節點的訪問狀態更改為“限制訪問”,查詢所述數據存儲節點對應的數據加載節點的個數及加載狀態;
如果所述數據存儲節點對應的數據加載節點的個數為零或所述數據存儲節點對應的數據加載節點均完成加載,則釋放所述數據存儲節點內存中的數據。
進一步的,所述如果所述數據存儲節點對應的數據加載節點的個數為零或所述數據存儲節點對應的數據加載節點均完成加載,則釋放所述數據存儲節點內存中的數據之后,還包括:
將接收所述獲取到的左孩子節點的待存儲數據存入磁盤,直至所述待存儲數據全部存入磁盤;
將所述數據存儲節點的訪問狀態更改為“完全訪問”,并觸發所述數據加載節點繼續執行加載。
進一步的,所述根據獲取到的左孩子節點的待存儲數據,確定所述待存儲數據對應的內存空間,所述內存空間包括一個或多個內存切片,每一內存切片對應所述待存儲數據中的子數據之前,包括:
設置自身的存儲狀態為“完全訪問”;
該專利技術資料僅供研究查看技術是否侵權等信息,商用須獲得專利權人授權。該專利全部權利屬于上海達夢數據庫有限公司,未經上海達夢數據庫有限公司許可,擅自商用是侵權行為。如果您想購買此專利、獲得商業授權和技術合作,請聯系【客服】
本文鏈接:http://www.szxzyx.cn/pat/books/202011490796.5/2.html,轉載請聲明來源鉆瓜專利網。
- 上一篇:一種多功能手套
- 下一篇:一種同步實現熱解氣脫除和原位焦制備的裝置
- 數據顯示系統、數據中繼設備、數據中繼方法、數據系統、接收設備和數據讀取方法
- 數據記錄方法、數據記錄裝置、數據記錄媒體、數據重播方法和數據重播裝置
- 數據發送方法、數據發送系統、數據發送裝置以及數據結構
- 數據顯示系統、數據中繼設備、數據中繼方法及數據系統
- 數據嵌入裝置、數據嵌入方法、數據提取裝置及數據提取方法
- 數據管理裝置、數據編輯裝置、數據閱覽裝置、數據管理方法、數據編輯方法以及數據閱覽方法
- 數據發送和數據接收設備、數據發送和數據接收方法
- 數據發送裝置、數據接收裝置、數據收發系統、數據發送方法、數據接收方法和數據收發方法
- 數據發送方法、數據再現方法、數據發送裝置及數據再現裝置
- 數據發送方法、數據再現方法、數據發送裝置及數據再現裝置





