買專利賣專利找龍圖騰，真高效！ 查專利查商標(biāo)用IPTOP,全免費(fèi)！專利年費(fèi)監(jiān)控用IP管家,真方便！

龍圖騰網(wǎng)獲悉北京科杰科技有限公司申請的專利一種基于FlinkSql的高效多源數(shù)據(jù)輸出方法獲國家發(fā)明授權(quán)專利權(quán)，本發(fā)明授權(quán)專利權(quán)由國家知識(shí)產(chǎn)權(quán)局授予，授權(quán)公告號(hào)為：CN120255863B 。

龍圖騰網(wǎng)通過國家知識(shí)產(chǎn)權(quán)局官網(wǎng)在2025-09-16發(fā)布的發(fā)明授權(quán)授權(quán)公告中獲悉：該發(fā)明授權(quán)的專利申請?zhí)?專利號(hào)為：202510743850.9，技術(shù)領(lǐng)域涉及：G06F8/30；該發(fā)明授權(quán)一種基于FlinkSql的高效多源數(shù)據(jù)輸出方法是由高海玲;高經(jīng)郡;朱孟澤設(shè)計(jì)研發(fā)完成，并于2025-06-05向國家知識(shí)產(chǎn)權(quán)局提交的專利申請。

本一種基于FlinkSql的高效多源數(shù)據(jù)輸出方法在說明書摘要公布了：本發(fā)明涉及多源數(shù)據(jù)輸出技術(shù)領(lǐng)域，尤其涉及一種基于FlinkSql的高效多源數(shù)據(jù)輸出方法，該方法基于不同的連接器表，編寫若干個(gè)INSERTINTO語句，用于將處理后的數(shù)據(jù)插入相應(yīng)的目標(biāo)表；基于若干所述INSERTINTO語句的數(shù)據(jù)依賴傾向值或若干所述INSERTINTO語句的作業(yè)拓?fù)浣Y(jié)構(gòu)的復(fù)雜程度確定對若干所述INSERTINTO語句動(dòng)態(tài)配置并行度或靜態(tài)配置并行度；在對若干所述INSERTINTO語句動(dòng)態(tài)配置并行度時(shí)，基于若干個(gè)INSERTINTO語句的數(shù)據(jù)冷熱分布類型和或數(shù)據(jù)關(guān)聯(lián)復(fù)雜程度確定初始并行度，并基于若干個(gè)INSERTINTO語句的數(shù)據(jù)新鮮容忍度和或?qū)崟r(shí)數(shù)據(jù)延遲確定動(dòng)態(tài)增大初始并行度或動(dòng)態(tài)減小初始并行度，本發(fā)明通過提高對INSERTINTO語句分析的精準(zhǔn)性進(jìn)而精準(zhǔn)配置并行度以提高輸出效率。

本發(fā)明授權(quán)一種基于FlinkSql的高效多源數(shù)據(jù)輸出方法在權(quán)利要求書中公布了：1.一種基于FlinkSql的高效多源數(shù)據(jù)輸出方法，其特征在于，包括： 運(yùn)用CREATETABLE語句創(chuàng)建多個(gè)不同的連接器表，每個(gè)連接器表對應(yīng)一個(gè)數(shù)據(jù)源或者目標(biāo)，同時(shí)確定數(shù)據(jù)的格式、存儲(chǔ)位置以及連接信息； 使用SELECT語句編寫業(yè)務(wù)邏輯，對輸入數(shù)據(jù)進(jìn)行查詢、轉(zhuǎn)換和聚合操作； 基于不同的連接器表，編寫若干個(gè)INSERTINTO語句，用于將SELECT語句處理后的數(shù)據(jù)插入相應(yīng)的目標(biāo)表； 基于若干所述INSERTINTO語句的數(shù)據(jù)依賴傾向值或若干所述INSERTINTO語句的作業(yè)拓?fù)浣Y(jié)構(gòu)的復(fù)雜程度確定對若干所述INSERTINTO語句動(dòng)態(tài)配置并行度； 在對若干所述INSERTINTO語句動(dòng)態(tài)配置并行度時(shí)，基于若干個(gè)INSERTINTO語句的數(shù)據(jù)冷熱分布類型和或數(shù)據(jù)關(guān)聯(lián)復(fù)雜程度確定初始并行度，并基于若干個(gè)INSERTINTO語句的數(shù)據(jù)新鮮容忍度和或?qū)崟r(shí)數(shù)據(jù)延遲確定動(dòng)態(tài)增大初始并行度或動(dòng)態(tài)減小初始并行度； 實(shí)時(shí)監(jiān)測每個(gè)INSERTINTO語句對應(yīng)的任務(wù)進(jìn)度，并基于處理任務(wù)執(zhí)行偏差程度與預(yù)設(shè)偏差程度，或資源彈性值是否出現(xiàn)波動(dòng)的判定結(jié)果，針對動(dòng)態(tài)配置并行度的判斷參數(shù)進(jìn)行調(diào)整； 若干所述INSERTINTO語句的數(shù)據(jù)依賴傾向值根據(jù)若干個(gè)INSERTINTO語句中存在強(qiáng)依賴關(guān)系的INSERTINTO語句數(shù)量與若干個(gè)INSERTINTO語句總數(shù)量的比值確定； 所述數(shù)據(jù)新鮮容忍度根據(jù)數(shù)據(jù)更新頻率確定。

如需購買、轉(zhuǎn)讓、實(shí)施、許可或投資類似專利技術(shù)，可聯(lián)系本專利的申請人或?qū)＠麢?quán)人北京科杰科技有限公司，其通訊地址為：100089 北京市海淀區(qū)東升科技園北街6號(hào)院10號(hào)樓11層101；或者聯(lián)系龍圖騰網(wǎng)官方客服，聯(lián)系龍圖騰網(wǎng)可撥打電話0551-65771310或微信搜索“龍圖騰網(wǎng)”。