US 2008/0288441 A1 · Processing method of data stream using Border Monitoring Query

Abstract

The present invention relates to a processing method of data stream using Border Monitoring Query, and more particularly a monitoring method and a system for data streams which are a large volume of data and continuously generated such as financial ticker, GPS data or a ubiquitous sensor network (USN). The objectives of the present invention are to process a large number of BMQs over data streams in high-performance and scalable manner. For this purpose, the invention presents BMQ-Index, a scalable and high performance data stream monitoring framework. The main idea of BMQ-Index is shared and incremental processing. For shared processing, BMQ-Index adopts a query indexing approach, thereby achieving a high level of scalability. Once BMQ-Index is built on registered queries, only relevant queries are quickly searched for upon an incoming data. For incremental processing, BMQ-Index employs an incremental access method, i.e., an index structure to store delta query information and an incremental search algorithm. Thus, successive BMQ evaluations are greatly accelerated.

Claims36

Dependent claims

In a system including the central processing unit, the database storing the BMQ-Index, the data stream sensor, a method which processes data streams using Border Monitoring Query, comprising;

Step 1 identifying a data stream in the sensor;
Step 2 checking an ID of the data stream in the central processing unit, testing whether the data stream is registered in the BMQ-Index or not, and identifying that it is registered;
Step 3 assigning a new node pointer based on the new data value for the data stream in the central processing unit;
Step 4 processing the new information for the data stream using the BMQ-Index in the central processing unit, and;
Step 5 updating the previous BMQ-Index for the data stream with the new node pointer and new data value in the central processing unit.

2 more elements

In a system containing a central processing unit, a input unit for the central processing unit, and a database storing a BMQ-index, a method of modifying the BMQ-index, comprising:

The step inputting a query to be changed and the corresponding query region from the input unit to the central processing unit;
The step assigning a region segment and delta query sets based on borders of query to be changed in the central processing unit;
The step setting up new borders of region segments (b0, b1, . . . , bm) and the corresponding new nodes (N1, N2, . . . , Nm) in the central processing unit;
and
The step storing each RS node and its region and delta query sets into the database in the central processing unit.

2 more elements

Dependencies are inferred from the claim text.

Processing method of data stream using Border Monitoring Query

Life of this patent

Processing method of data stream using Border Monitoring Query

Life of this patent

Abstract

Claims36