Apparatus for processing integrated query from various sensor networks and method thereof

• US 7,882,133 B2
• Filed: 10/31/2007
• Issued: 02/01/2011
• Est. Priority Date: 11/08/2006
• Status: Active Grant

• Current Assignee: Electronics and Telecommunications Research Institute
• Original Assignee: Electronics and Telecommunications Research Institute
• Inventors: Jang, In-Sung, Park, Jong-Hyun, Kim, Mal-Hee, Lee, Jun-Wook, Kim, Min-Soo, Yoo, Jae-Jun, Lee, Yong-Joon
• Primary Examiner(s): Channavajjala; Srirama
• Assistant Examiner(s): Le; Jessica N
• Application Number:
  US11/933,037
• Publication Number:
  US 20080109421A1
• Time in Patent Office: 1,189 Days
• Field of Search: None
• US Class Current: 707/790
• CPC Class Codes: G06F 16/2477 Temporal data queries

Abstract

An apparatus for processing an integrated query from various sensor networks and a method thereof are provided. The apparatus includes an integrated query parser for parsing an integrated query and analyzing a syntax of the parsed integrated query; an integrated query execution plan generator for analyzing meaning of the parsed integrated query and generating an integrated query execution query for processing an integrated query; an integrated query optimizer for optimizing a process time for the generated execution plan based on query information stored in the query information storage and sensor network information stored in the sensor network information storage; and an integrated query executer for detailing the integrated query execution plan by controlling an execution order according to the optimized integrated query and transferring the detailed integrated query execution plan to an event data process executer, a temporal data process executer, and a continuous data process executer.

Claims

1. An apparatus comprising a processor to integrally process an integrated query for sensor data of a plurality of heterogeneous sensor networks, the processor comprising:

an integrated query parsing unit to parse the integrated query and to analyze a syntax of the parsed integrated query;

an integrated query execution plan generation unit to analyze a meaning of the parsed integrated query and to generate an integrated query execution plan for processing the integrated query;

an integrated query optimizing unit to optimize a process time for the generated integrated query execution plan based on query information and sensor network information; and

an integrated query execution unit to detail the integrated query execution plan by controlling an execution order according to the optimized integrated query from the integrated query optimizing unit and to transfer the detailed integrated query execution plan to an event data process execution unit, a temporal data process execution unit, and a continuous data process execution unit according to the sensing data of the integrated query, the sensing data comprising at least two types of data among event data, temporal data, and continuous data,

wherein continuous data is data sensed by a first heterogeneous sensor network and continuously returned to the apparatus, and temporal data is data sensed by a second heterogeneous sensor network and returned to the apparatus at a predetermined time, and

wherein the integrated query execution unit comprises;

an execution plan scheduling unit to decide an execution order for the optimized integrated query execution plan from the integrated query optimizing unit;

an execution plan changing unit to detail the optimized integrated query execution plan according to a query performing order inputted from the execution plan scheduling unit, including a process of a predetermined sensor network in an execution plan or changing an execution plan according to a data type to process, and transferring the integrated query execution plan to the event data process execution unit, the temporal data process execution unit, or the continuous data process execution unit; and

a data converting unit to convert event data, temporal data, or continuous data, which is transmitted from the event data process execution unit, the temporal data process execution unit, or the continuous data process execution unit as a result of the integrated query, to a predetermined data type.

2. The apparatus of claim 1, wherein the integrated query execution unit analyzes the integrated query for inputted sensing data to determine whether the integrated query is able to be processed to be suitable to a predetermined data type, classifies a processable integrated query into a query for a predetermined data type according to the analyzing result, and processes the classified query.

3. The apparatus of claim 1, wherein if the execution results transferred from the temporal data process execution unit and the continuous data process execution unit are in different data formats, the data formats of the execution results are converted by the data converting unit to match.

4. The apparatus of claim 1, wherein the event data process execution unit comprises:

an event data process execution analyzing unit to analyze a syntax and a meaning of an event data process execution plan transferred from the execution plan scheduling unit;

an event data process execution plan optimizing unit to reduce a process time for the analyzed event data process execution plan from the event data process execution plan analyzing unit; and

an event data result obtaining unit to process a query for event data according to the optimized event data process execution plan from the event data process execution plan optimizing unit.

5. The apparatus of claim 1, wherein the temporal data process execution unit comprises:

a temporal data process execution analyzing unit to analyze a syntax and a meaning of a temporal data process execution plan transferred from the execution plan scheduling unit;

a temporal data process execution plan optimizing unit to reduce a process time for the analyzed temporal data process execution plan from the temporal data process execution plan analyzing unit; and

a temporal data result obtaining unit to process a query for temporal data according to the optimized temporal data process execution plan from the temporal data process execution plan optimizing unit.

6. The apparatus of claim 1, wherein the event data is obtained from the temporal data and the continuous data through data conversion if a predetermined condition is satisfied.

7. The apparatus of claim 1, wherein the temporal data is obtained by extracting a predetermined part from the continuous data and by repeatedly extracting a predetermined part from the continuous data.

8. A method for processing an integrated query for a plurality of heterogeneous sensor networks by an apparatus comprising a processor, a query information storing unit, and a sensor network information storing unit, in order to process an integrated query according to the sensing data of the integrated query, the sensing data comprising at least two types of data among event data, temporal data, and continuous data, the method comprising the step of:

parsing the integrated query and analyzing syntax of the parsed integrated query;

analyzing a meaning of the analyzed integrated query and generating an integrated query execution plan for processing the integrated query;

optimizing the integrated query execution plan for reducing a process time for the generated integrated query execution plan based on query information stored in the query information storing unit and sensor network information stored in the sensor network information storing unit;

detailing the integrated query execution plan to be suitable for each data type by controlling an execution order for the optimized integrated query execution plan;

performing a query according to an event data process execution plan if the detailed integrated query execution plan includes the event data process execution plan;

performing a query according to a temporal data process execution plan if the detailed integrated query execution plan includes the temporal data process execution plan;

performing a query according to a continuous data process execution plan if the detailed integrated query execution plan includes the continuous data process execution plan;

performing a query according to a post process execution plan if the post process execution plan for obtaining a final result is included after the detailed integrated query execution plan is completely processed; and

calling a registered event handler according to needs if a data type of the final result is event data,

wherein continuous data is data sensed by a first heterogeneous sensor network and continuously returned to the apparatus, and temporal data is data sensed by a second heterogeneous sensor network and returned to the apparatus at a predetermined time, and

the method further comprises;

converting an execution result data format for matching data formats of execution results if a data format obtained by the temporal data process execution plan and a data format obtained by the continuous data process execution plan are different,

wherein the event data is obtained from the temporal data or the continuous data through data conversion if a predetermined condition is satisfied, and

wherein the temporal data is obtained by extracting a predetermined part from the continuous data or by repeatedly extracting a predetermined part from the continuous data.

9. The method of claim 8, wherein the step of detailing the integrated query execution plan includes the steps of:

deciding an execution order for the optimized integrated query execution plan; and

detailing the optimized integrated query execution plan according to the decided execution order, and including a process of a predetermined sensor network in an execution plan or changing an execution plan according to a data type to process.