[發明專利]延遲容忍度時間區間更新方法、裝置、電子設備和介質

在審

• 申請號: 202111479286.2
• 申請日: 2021-12-06
• 公開（公告）號: CN114116807A
• 公開（公告）日: 2022-03-01
• 發明（設計）人: 陳健璋
• 申請（專利權）人: 北京京東振世信息技術有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F16/2458
• 代理公司: 北京唯智勤實知識產權代理事務所(普通合伙) 11557
• 代理人: 史立狀

本公開的實施例公開了延遲容忍度時間區間更新方法、裝置、電子設備和介質。該方法的一具體實施方式包括：響應于確定等待時長集合滿足預設條件，根據等待時長集合生成目標概率密度函數，其中，等待時長集合中的等待時長是需要進行關聯的目標流和源流中的數據的相互等待時長；基于目標概率密度函數，確定等待時長上限值和等待時長下限值；將延遲容忍度時間區間的上限值和下限值分別更新為等待時長上限值和等待時長下限值。該實施方式可以在確保絕大多數數據完成關聯邏輯外，最大限度的節省緩存資源。

技術領域

本公開的實施例涉及計算機技術領域，具體涉及延遲容忍度時間區間更新方法、裝置、電子設備和介質。

背景技術

在基于時間間隔的兩流數據關聯的應用場景中，需要對兩流數據中擁有相同主鍵值、且彼此之間時間間隔不超過指定時間間隔的數據進行關聯后下發。目前，在基于時間間隔的兩流數據關聯中，通常采取的方式為：設置固定的延遲容忍度時間區間，直接丟棄未在延遲容忍度時間區間內匹配到關聯數據的數據，緩存所有時間戳大于當前水位線加延遲容忍度時間區間的下限值的數據。

然而，當采用上述方式對兩流數據關聯時，經常會存在如下技術問題：

實際中，兩個數據流中的數據的到來順序及前后時間差無法確切估計，若延遲容忍度時間區間設置的過短，則會導致大量數據因未匹配成功而被丟棄，無法實現精準一次；若延遲容忍度時間區間設置的過長，將耗費大量內存緩存數據，浪費存儲資源。

發明內容

本公開的內容部分用于以簡要的形式介紹構思，這些構思將在后面的具體實施方式部分被詳細描述。本公開的內容部分并不旨在標識要求保護的技術方案的關鍵特征或必要特征，也不旨在用于限制所要求的保護的技術方案的范圍。

本公開的一些實施例提出了延遲容忍度時間區間更新方法、裝置、電子設備和介質，來解決以上背景技術部分提到的技術問題。

第一方面，本公開的一些實施例提供了一種延遲容忍度時間區間更新方法，該方法包括：響應于確定等待時長集合滿足預設條件，根據上述等待時長集合生成目標概率密度函數，其中，上述等待時長集合中的等待時長是需要進行關聯的目標流和源流中的數據的相互等待時長；基于上述目標概率密度函數，確定等待時長上限值和等待時長下限值；將延遲容忍度時間區間的上限值和下限值分別更新為上述等待時長上限值和上述等待時長下限值。

可選的，上述基于上述目標概率密度函數，確定等待時長上限值和等待時長下限值，包括：將上述目標概率密度函數的最大值對應的自變量的數值確定為分隔數值；確定上述目標概率密度函數在負無窮至上述分隔數值之間的區間內的最小值對應的自變量的數值，得到等待時長下限值；確定上述目標概率密度函數在上述分隔數值至正無窮之間的區間內的最小值對應的自變量的數值，得到等待時長上限值。

可選的，上述預設條件是上述等待時長集合中包括的等待時長的數目大于或者等于目標數目；以及在上述響應于確定等待時長集合滿足預設條件，根據上述等待時長集合生成目標概率密度函數之后，上述方法還包括：清空上述等待時長集合。

可選的，上述方法還包括：響應于接收到來自于上述目標流或者上述源流中的、且未匹配到關聯數據的從表數據，確定上述從表數據的來源；響應于確定上述從表數據來自于上述源流，根據接收到上述從表數據的時間和上述延遲容忍度時間區間的下限值，確定第一等待時段；響應于在上述第一等待時段內從上述目標流中接收到與上述從表數據相匹配的關聯數據，將接收到上述從表數據的時間與接收到上述關聯數據的時間的時間差值確定為等待時長。

可選的，上述方法還包括：響應于在上述第一等待時段內未從上述目標流中接收到與上述從表數據相匹配的關聯數據，選取上述延遲容忍度時間區間的下限值作為等待時長。