Specifying A Family Of Logics Defining Windows In Data Stream Management Systems

• US 20090112803A1
• Filed: 10/30/2007
• Published: 04/30/2009
• Est. Priority Date: 10/30/2007
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Mishra, Shailendra, Jain, Namit, Jain, Parul, Srinivasan, Anand
• Granted Patent: US 8,103,655 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/903 Querying for retrieval from the web G06F16/953

Abstract

Simplifying a user'"'"'s task in specifying a family of logics, with each logic designed to potentially select different subsets of values from the same continuous data stream at the same time instant. In one embodiment, all the logics are together specified by a common user specified software code design to accept a set of parameters, with different logics resulting from execution of the software code with different parametric values. Thus, when closely related family of logics are to be developed, the common software code may be formulated, with the code being designed to accept parameters and providing different logics for different sets of parametric values corresponding to the parameters.

Claims

1. A method of supporting a family of logics defining windows of continuous data streams in a data stream management system, said method comprising:

receiving a common software code designed to execute using a set of values as parameters, wherein execution of said common software code with a corresponding set of values results in a corresponding one of said family of logics;

receiving a query to be executed on a continuous data stream, wherein said first query specifies a first set of parametric values corresponding to a desired logic contained in said family of logics;

determining a set of data values to be included in a first window by executing said software code using said first set of parametric values as said set of values, wherein said set of data values is contained in a plurality of data values received in said continuous data stream; and

generating an output of said query based on said set of data values included in said first window.

2. The method of claim 1, further comprising:

receiving a second query to be executed on said continuous data stream, wherein said second query specifies a second set of parametric values corresponding to another desired logic contained in said family of logics,

wherein said determining determines a second set of data values contained in said plurality of data values to be included in a second window by executing said software code using said second set of parametric values as said set of values,

wherein said generating generates a second output of said second query based on said second set of data values forming said second window at a corresponding time instant.

3. A machine readable medium storing one or more sequences of instructions for causing a data stream management system to support a family of logics defining windows of continuous data streams, wherein execution of said one or more sequences of instructions by one or more processors contained in said data stream management system causes said data stream management system to perform the actions of:

receiving a common software code designed to execute using a set of values as parameters, wherein execution of said common software code with a corresponding set of values results in a corresponding one of said family of logics;

receiving a query to be executed on a continuous data stream, wherein said first query specifies a first set of parametric values corresponding to a desired logic contained in said family of logics;

determining a set of data values to be included in a first window by executing said software code using said first set of parametric values as said set of values, wherein said set of data values is contained in a plurality of data values received in said continuous data stream; and

generating an output of said query based on said set of data values included in said first window.

4. The machine readable medium of claim 3, further comprising one or more instructions for:

receiving a second query to be executed on said continuous data stream, wherein said second query specifies a second set of parametric values corresponding to another desired logic contained in said family of logics,

wherein said determining determines a second set of data values contained in said plurality of data values to be included in a second window by executing said software code using said second set of parametric values as said set of values,

wherein said generating generates a second output of said second query based on said second set of data values forming said second window at a corresponding time instant.

5. A data stream management system for supporting a family of logics defining windows of continuous data streams, said data stream management system comprising:

means for receiving a common software code designed to execute using a set of values as parameters, wherein execution of said common software code with a corresponding set of values results in a corresponding one of said family of logics;

means for receiving a query to be executed on a continuous data stream, wherein said first query specifies a first set of parametric values corresponding to a desired logic contained in said family of logics;

means for determining a set of data values to be included in a first window by executing said software code using said first set of parametric values as said set of values, wherein said set of data values is contained in a plurality of data values received in said continuous data stream; and

means for generating an output of said query based on said set of data values included in said first window.

6. The data stream management system of claim 5, further comprising:

means for receiving a second query to be executed on said continuous data stream, wherein said second query specifies a second set of parametric values corresponding to another desired logic contained in said family of logics,

wherein said means for determining determines a second set of data values contained in said plurality of data values to be included in a second window by executing said software code using said second set of parametric values as said set of values,

wherein said means for generating generates a second output of said second query based on said second set of data values forming said second window at a corresponding time instant.