APPARATUS FOR PROCESSING INTEGRATED QUERY FROM VARIOUS SENSOR NETWORKS AND METHOD THEREOF

• US 20080109421A1
• Filed: 10/31/2007
• Published: 05/08/2008
• Est. Priority Date: 11/08/2006
• Status: Active Grant

• Current Assignee: Electronics and Telecommunications Research Institute
• Original Assignee: Electronics and Telecommunications Research Institute
• Inventors: KIM, Min-Soo, JANG, In-Sung, LEE, Jun-Wook, PARK, Jong-Hyun, YOO, Jae-Jun, KIM, Mal-Hee, LEE, Yong-Joon
• Granted Patent: US 7,882,133 B2
• Time in Patent Office: Days
• US Class Current: 707/4
• 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 for integrally processing sensor data to process an integrated query of a plurality of heterogeneous sensor networks, the apparatus comprising:

an integrated query parsing means for parsing an inputted integrated query and analyzing a syntax of the parsed integrated query;

an integrated query execution plan generation means for analyzing meaning of the parsed integrated query and generating an integrated query execution query for processing an integrated query;

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

an integrated query execution means for detailing the integrated query execution plan by controlling an execution order according to the optimized integrated query from the integrated query optimizing means and transferring the detailed integrated query execution plan to an event data process execution means, a temporal data process execution means, and a continuous data process execution means.

2. The apparatus of claim 1, wherein the integrated query execution means analyzes integrated query for inputted sensing data such as event data, temporal data, and continuous data whether the integrated query can 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 the integrated query execution means includes:

an execution plan scheduling means for deciding an execution order for the optimized integrated query execution plan from the integrated query optimizing means;

an execution plan changing means for detailing the optimized execution plan according to a query performing order inputted from the execution plan scheduling means, 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 execution plan to the event data process execution means, the temporal data process execution means, or the continuous data process execution means; and

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

4. The apparatus of claim 3, wherein if the data converting means executing results transferred from the temporal data process execution means and the continuous data process execution means are different in a data format, the data formats of the execution results are converted to match the data formats.

5. The apparatus of claim 3, wherein the event data process execution means includes:

an event data process execution analyzing means for analyzing a syntax and a meaning of an event data process execution plan transferred from the execution plan scheduling means;

an event data process execution plan optimizing means for reducing a process time for the analyzed event data process execution plan from the event data process execution plan analyzing means; and

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

6. The apparatus of claim 3, wherein the temporal data process execution means includes:

a temporal data process execution analyzing means for analyzing a syntax and a meaning of a temporal data process execution plan transferred from the execution plan scheduling means;

a temporal data process execution plan optimizing means for reducing a process time for the analyzed temporal data process execution plan from the temporal data process execution plan analyzing means; and

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

7. The apparatus of claim 3, wherein the continuous data process execution means includes:

a continuous data process execution analyzing means for analyzing a syntax and a meaning of a continuous data process execution plan transferred from the execution plan scheduling means;

a continuous data process execution plan optimizing means for reducing a process time for the analyzed continuous data process execution plan from the continuous data process execution plan analyzing means; and

a continuous data result obtaining means for processing a query for continuous data according to the optimized continuous data process execution plan from the continuous data process execution plan optimizing means.

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

9. The apparatus of claim 3, 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.

10. A method for processing an integrated query for a plurality of heterogeneous sensor networks in order to process an integrated query for event data, temporal data, and continuous data, comprising the step of:

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

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

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

detailing the integrated query execution plan to be suitable 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 execution plan includes the event data process execution plan;

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

performing a query according to a continuous data process execution plan if the detailed 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 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.

11. The method of claim 10, 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 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.

12. The method of claim 10, further comprising 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.

13. The method of claim 12, wherein the event data is obtained from the temporal data or the continuous data through data conversion if a predetermined condition is satisfied.

14. The method of claim 13, 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.