[發明專利]用于對數據流執行信息處理的設備和方法

在審

• 申請號: 202010872238.9
• 申請日: 2016-08-26
• 公開（公告）號: CN112148753A
• 公開（公告）日: 2020-12-29
• 發明（設計）人: 拉杜·圖多蘭;戈茲·布蘭切;朱星
• 申請（專利權）人: 華為技術有限公司
• 主分類號: G06F16/2455
• 分類號: G06F16/2455;G06F17/18
• 代理公司: 暫無信息
• 代理人: 暫無信息

本發明涉及一種設備和方法，所述設備和方法均用于通過對數據流執行信息處理來生成部分結果，其中，所述設備用于通過實施包括多個級別的流窗口層級以及在所述流窗口層級的每個級別生成部分結果來處理所述數據流內包含的信息。

技術領域

本發明涉及一種設備和方法，該設備和方法均用于對數據流執行信息處理，以及在信息處理過程中生成部分結果。此外，本發明涉及一種相應布置的計算機程序產品和一種相應布置的計算機可讀介質。

背景技術

由于系統和應用日漸增多，流處理方法變得日益重要，在這些系統和應用中，一個或多個設備生成的數據被傳送給另一個負責分析所述數據的設備。流處理在多個用例中實施。具體地，流處理包括分析來自一個或多個提供數據流的來源的一個或多個數據流。該處理實時執行。因此，處理的速度和結果的準確性是主要問題。

通常，不僅關注流處理過程的最終結果，還關注中間結果或部分結果。在提供的用例中，這樣的中間或部分結果概述或評估了給定情形或者系統狀態等。

例如，一個或多個傳感器可持續上報測量數據給處理和分析該測量數據的設備。這些測量數據可能，例如，對于控制過程很重要，例如對系統或生產過程的控制很重要。如果測量數據涉及的系統必須保持某一特定狀態，那么分析測量數據的部分分析結果也很重要，以便不斷監測系統狀態。

本文提供了若干場景，在這些場景中，持續呈現部分結果是有用的，有時甚至很重要(例如，為了維持系統的正確運行)。

因此，需要能夠以快速有效的方式執行流處理并且提供快速可靠的部分結果的設備和方法。

發明內容

本發明的目的在于提供一種能夠改進數據流處理的方法和設備，在所述數據流處理中還支持確定部分結果。

本發明提供了一種用于通過對數據流執行信息處理，以高效準確的方式來生成部分結果的方法和設備。具體而言，根據本發明實施流窗口層級，使得所需的部分結果以高效可靠的方式在所述流窗口層級的每個級別生成。

上述流窗口是已知的。它們將數據流細分或離散為不重疊的窗口，即，所述數據流的各部分，使得所述流處理分別在各部分或者各窗口進行，其中，每一次執行處理都涉及所述數據流的相應部分。通常只使用一個窗口。通過所述窗口來處理所述數據流的被設定為特定窗口尺寸的窗口覆蓋的部分。在處理所述流的被所述窗口覆蓋的所述部分后，所述窗口沿著所述流滑動到所述流的下一部分，所述下一部分在那之前還未進行處理且貼合所述窗口。所述數據流的所述下一部分的相關處理再次開始。這些窗口具有特定的預定尺寸，因此處理的是具有特定的預定長度的數據流。

本發明的目的通過所附獨立權利要求中提供的方案實現。本發明的有利實施方式在本說明書的相應從屬權利要求和/或附圖中進一步限定。

根據第一方面，提供了一種用于通過對數據流執行信息處理來生成部分結果的設備，所述設備用于通過實施包括多個級別i的流窗口層級以及在所述流窗口層級的每個級別生成部分結果來處理所述數據流內包含的信息，其中，i＝1、……、n，n≥2。

所述部分結果代表數據處理過程的中間結果。時間敏感應用或系統等可能需要或者要求這類結果。所述部分結果可在計算或確定最終結果時按預定的時間間隔輸出或提供。所述流窗口層級被劃分為按一定順序排列的若干級別。換言之，所述流窗口層級包含多個級別。

通過實施所述生成部分結果的流窗口層級，提供了一種用于快速有效地提供部分結果并計算或確定最終結果的工具。部分和最終結果的計算效率是處理數據流的關鍵問題。大數據的處理耗費資源和時間。另一方面，期望快速提供部分和最終結果，因為所述部分和最終結果用于執行進一步的過程，在這些過程中會基于所述結果作出進一步的決策(例如，關于控制，關于需在系統或應用中執行的其它步驟)。通過所述流窗口層級，解決了效率問題。另外，解決所述效率問題并未增加處理數據流的信息所需的資源量，而是將所需的資源量保持在很小。