Specifying a family of logics defining windows in data stream management systems

• US 8,103,655 B2
• Filed: 10/30/2007
• Issued: 01/24/2012
• Est. Priority Date: 10/30/2007
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Srinivasan, Anand, Jain, Namit, Jain, Parul, Mishra, Shailendra
• Primary Examiner(s): Trujillo, James
• Assistant Examiner(s): Casanova, Jorge A
• Application Number:
  US11/927,683
• Publication Number:
  US 20090112803A1
• Time in Patent Office: 1,547 Days
• Field of Search: 707/713, 707/769
• US Class Current: 707/713
• 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 for said parameters results in a corresponding one of said family of logics;

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

identifying a plurality of data values, among many data values received by said data stream management system, as being received in said continuous data stream;

determining, from among said plurality of data values identified as being received in said continuous data stream, a set of data values to be included in a first window corresponding to a first time instant based on said desired logic caused by executing said software code using said first set of parametric values as said set of values,

wherein said identifying identifies a first data value as being received in said continuous data stream, wherein said determining comprises;

checking whether said first data value is to be included in said window by executing said software code using said first set of parametric values as said set of values; and

adding said first data value to said set of data values, only if said first data value is to be included in said first window; and

generating an output of said query for said first time instant by processing 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, from among said plurality of data values identified as being received in said continuous data stream, a second set of data values to be included in a second window corresponding to a second time instant based on said desired logic caused 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 for said second time instant by processing said second query based on said second set of data values forming said second window at said second time instant.

3. The method of claim 1, wherein said common software code contains at least one programming instruction according to a programming language.

4. The method of claim 3, wherein said common software code including said programming instruction, when executed using said first set of parametric values as said set of values, specifies a corresponding width in terms of a time interval for said first window at each of a corresponding time instants, wherein the width is variable and not equal for at least two of said time instants.

5. 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 for said parameters results in a corresponding one of said family of logics;

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

identifying a plurality of data values, among many data values received by said data stream management system, as being received in said continuous data stream;

determining, from among said plurality of data values identified as being received in said continuous data stream, a set of data values to be included in a first window corresponding to a first time instant based on said desired logic caused by executing said software code using said first set of parametric values as said set of values,

wherein said identifying identifies a first data value as being received in said continuous data stream, wherein said determining comprises;

checking whether said first data value is to be included in said window by executing said software code using said first set of parametric values as said set of values; and

adding said first data value to said set of data values, only if said first data value is to be included in said first window; and

generating an output of said query for said first time instant by processing said query based on said set of data values included in said first window.

6. The machine readable medium of claim 5, 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, from among said plurality of data values identified as being received in said continuous data stream, a second set of data values to be included in a second window corresponding to a second time instant based on said desired logic caused 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 for said second time instant by processing said second query based on said second set of data values forming said second window at said second time instant.

7. The machine readable medium of claim 5, wherein said common software code contains at least one programming instruction according to a programming language.

8. The machine readable medium of claim 7, wherein said common software code including said programming instruction, when executed using said first set of parametric values as said set of values, specifies a corresponding width in terms of a time interval for said first window at each of a corresponding time instants, wherein the width is variable and not equal for at least two of said time instants.

9. A computing system comprising:

a plurality of data sources to send data values;

a client system to send a common software code and a query, wherein said common software code is designed to execute using a set of values as parameters, wherein execution of said common software code with a corresponding set of values for said parameters results in a corresponding one of a family of logics,

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

a data stream management system configured to;

receive said common software code and said query from said client system;

identify a plurality of data values, among many data values received from said plurality of data sources, as being received in said continuous data stream specified in said query;

determine, from among said plurality of data values identified as being received in said continuous data stream, a set of data values to be included in a first window corresponding to a first time instant based on said desired logic caused by executing said software code using said first set of parametric values as said set of values; and

generate an output of said query for said first time instant by processing said query based on said set of data values included in said first window,

wherein said data stream management system identifies a first data value as being received in said continuous data stream, wherein to said determine, said data stream management system is further configured to;

check whether said first data value is to be included in said window by executing said software code using said first set of parametric values as said set of values; and

add said first data value to said set of data values, only if said first data value is to be included in said first window,

wherein each of at least some of said plurality of data source, said client system and said data stream management system are implemented using a corresponding processor which retrieves instructions from a corresponding memory and executes the retrieved instructions.

10. The computing system of claim 9, wherein said data stream management system is further configured to:

receive 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 data stream management system determines, from among said plurality of data values identified as being received in said continuous data stream, a second set of data values to be included in a second window corresponding to a second time instant based on said desired logic caused by executing said software code using said second set of parametric values as said set of values,

wherein said data stream management system generates a second output of said second query for said second time instant by processing said second query based on said second set of data values forming said second window at said second time instant.

11. The computing system of claim 9, wherein said common software code contains at least one programming instruction according to a programming language.

12. The computing system of claim 11, wherein said common software code including said programming instruction, when executed using said first set of parametric values as said set of values, specifies a corresponding width in terms of a time interval for said first window at each of a corresponding time instants, wherein the width is variable and not equal for at least two of said time instants.