DATA CONTINUOUS SQL PROCESS

• US 20100250572A1
• Filed: 03/26/2009
• Published: 09/30/2010
• Est. Priority Date: 03/26/2009
• Status: Active Grant

• Current Assignee: Hewlett Packard Enterprise Development LP (Hewlett-Packard Enterprise Company)
• Original Assignee: Hewlett-Packard Development Company, L.P. (HP Inc.)
• Inventors: Hsu, Meichun, Chen, Qiming
• Granted Patent: US 8,725,707 B2
• Time in Patent Office: Days
• US Class Current: 707/759
• CPC Class Codes: G06F 16/24565 Triggers; Constraints
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries

Abstract

One embodiment is a method that repeatedly triggers a User Defined Function (UDF) that generates a data stream. A data continuous Structured Query Language (SQL) query is applied to the data stream to construct a data continuous SQL process (DCSP) which executes in a database.

Claims

1. ) A method, comprising:

repeatedly triggering a User Defined Function (UDF) that generates a data stream;

applying, with a computer, a data continuous Structured Query Language (SQL) query to the data stream to construct a data continuous SQL process (DCSP); and

executing, in a database engine located in a database, the DCSP.

2. ) The method of claim 1, wherein the UDF is repeatedly triggered by stream inputs, timers, and event conditions.

3. ) The method of claim 1 further comprising, modeling the DCSP at a graph of stations that function as nodes and pipes that function as links between the nodes.

4. ) The method of claim 1 further comprising, constructing the DCSP from stations interconnected with pipes.

5. ) The method of claim 1 further comprising:

specifying data-stream-driven processes with SQL queries;

executing the data-stream-driven processes directly at a database management system (DBMS) level.

6. ) The method of claim 1 further comprising, executing UDFs under streamed Input/Outputs.

7. ) The method of claim 1, wherein the DCSP is data-stream driven and continuously running.

8. ) The method of claim 1 further comprising:

hosting continuously executing UDFs at plural stations;

using a pipe as a first-in-first-out (FIFO) stream container for asynchronous communicating between the stations.

9. ) A tangible computer readable storage medium having instructions for causing a computer to execute a method, comprising:

executing a continuous data stream process with three functions that include an extract, transform, load (ETL) process, an aggregation process, and reporting process;

specifying the continuous data stream process with Structured Query Language (SQL) queries; and

executing the SQL queries at a database management system (DBMS) level.

10. ) The tangible computer readable storage medium of claim 9, wherein the ETL process, the aggregation process, and the reporting process execute in different cycles with the ETL process executing more frequently than the reporting process.

11. ) The tangible computer readable storage medium of claim 9 further comprising, pushing down the continuous data stream process to the DBMS level to avoid round-trip traffic in data access and utilize parallel database communications to increase performance of executing the SQL queries.

12. ) The tangible computer readable storage medium of claim 9, wherein the ETL process, the aggregation process, and the reporting process are not cascaded on a performance execution basis since for every given number of plural executions of the ETL process the aggregate process executes only once.

13. ) The tangible computer readable storage medium of claim 9 further comprising, using pipes to connect stream data sources that include User Defined Functions (UDFs), queries, and fact tables.

14. ) A computer system, comprising:

a computer that generates a data continuous Structured Query Language (SQL) query to a continuous data stream to construct a data continuous SQL process (DCSP); and

a database in communication with the computer, the database including a database engine that executes the DCSP in the database.

15. ) The computer system of claim 14, wherein the DCSP is constructed from continuously running User Defined Functions (UDFs).

16. ) The computer system of claim 14, wherein execution of the DCSP occurs in the database to increase performance of executing queries to the database.

17. ) The computer system of claim 14, wherein User Defined Functions (UDFs) are triggered to repeatedly run by stream inputs to generate a data stream that is deposited to a stream table.

18. ) The computer system of claim 14, wherein User Defined Functions (UDFs) are triggered to repeatedly run by stream inputs to generate a data stream that is fed into other UDFs.

19. ) The computer system of claim 14, wherein User Defined Functions (UDFs) are triggered to repeatedly run by stream inputs and are not composed on a one-execution basis but coupled asynchronously together.

20. ) The computer system of claim 14 further comprising:

stations that host continuously executed User Defined Functions (UDFs);

pipes that function as first-in-first-out containers that connect the stations.