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

龍圖騰網(wǎng)恭喜北京思特奇信息技術(shù)股份有限公司申請的專利一種基于flink自定義sink的數(shù)據(jù)處理及推送方法及系統(tǒng)獲國家發(fā)明授權(quán)專利權(quán)，本發(fā)明授權(quán)專利權(quán)由國家知識產(chǎn)權(quán)局授予，授權(quán)公告號為：CN114661491B 。

龍圖騰網(wǎng)通過國家知識產(chǎn)權(quán)局官網(wǎng)在2025-05-16發(fā)布的發(fā)明授權(quán)授權(quán)公告中獲悉：該發(fā)明授權(quán)的專利申請?zhí)?專利號為：202210173702.4，技術(shù)領(lǐng)域涉及：G06F9/54；該發(fā)明授權(quán)一種基于flink自定義sink的數(shù)據(jù)處理及推送方法及系統(tǒng)是由肖燕珍設(shè)計研發(fā)完成，并于2022-02-24向國家知識產(chǎn)權(quán)局提交的專利申請。

本一種基于flink自定義sink的數(shù)據(jù)處理及推送方法及系統(tǒng)在說明書摘要公布了：本發(fā)明公開了一種基于flink自定義sink的數(shù)據(jù)處理及推送方法及系統(tǒng)，屬于數(shù)據(jù)處理技術(shù)領(lǐng)域。本發(fā)明方法，包括：對flink啟動命令中指定基本信息；在作業(yè)列表頁面啟動時，根據(jù)redis的值，判斷當(dāng)前作業(yè)對應(yīng)的主題是否已經(jīng)啟動了作業(yè)；若沒有啟動作業(yè)則發(fā)送flink啟動命令并啟動作業(yè)，新增接數(shù)主題和表的關(guān)系到redis中；若已經(jīng)啟動作業(yè)，則只新增接數(shù)主題和表的關(guān)系到redis；當(dāng)啟動作業(yè)過程中對應(yīng)的消息經(jīng)過flink啟動命令的計算邏輯時，會根據(jù)redis中作業(yè)對應(yīng)的表的json內(nèi)容，確定對應(yīng)的消息存儲的位置；在作業(yè)列表頁面停用時，若redis中接數(shù)主題對應(yīng)的表只剩下當(dāng)前作業(yè)對應(yīng)的表，則執(zhí)行yarnapplication?kill命令并關(guān)閉相應(yīng)的作業(yè)，刪除redis中接數(shù)主題和表的關(guān)系。本發(fā)明減少了資源的消耗，以及運維成本。

本發(fā)明授權(quán)一種基于flink自定義sink的數(shù)據(jù)處理及推送方法及系統(tǒng)在權(quán)利要求書中公布了：1.一種基于flink自定義sink的數(shù)據(jù)處理及推送方法，所述方法包括：對flink啟動命令中指定基本信息；在作業(yè)列表頁面啟動時，根據(jù)redis的值，判斷當(dāng)前作業(yè)對應(yīng)的主題是否已經(jīng)啟動了作業(yè)；若沒有啟動作業(yè)則發(fā)送flink啟動命令并啟動作業(yè)，新增接數(shù)主題和表的關(guān)系到redis中；若已經(jīng)啟動作業(yè)，則只新增接數(shù)主題和表的關(guān)系到redis；當(dāng)啟動作業(yè)過程中對應(yīng)的消息經(jīng)過flink啟動命令的計算邏輯時，會根據(jù)redis中作業(yè)對應(yīng)的表的json內(nèi)容，確定對應(yīng)的消息存儲的位置；在作業(yè)列表頁面停用時，若redis中接數(shù)主題對應(yīng)的表只剩下當(dāng)前作業(yè)對應(yīng)的表，則執(zhí)行yarnapplication-kill命令并關(guān)閉相應(yīng)的作業(yè)，刪除redis中接數(shù)主題和表的關(guān)系。

如需購買、轉(zhuǎn)讓、實施、許可或投資類似專利技術(shù)，可聯(lián)系本專利的申請人或?qū)＠麢?quán)人北京思特奇信息技術(shù)股份有限公司，其通訊地址為：100086 北京市海淀區(qū)中關(guān)村南大街6號14層；或者聯(lián)系龍圖騰網(wǎng)官方客服，聯(lián)系龍圖騰網(wǎng)可撥打電話0551-65771310或微信搜索“龍圖騰網(wǎng)”。