Value based windows on relations in continuous data streams

• US 9,418,113 B2
• Filed: 05/30/2013
• Issued: 08/16/2016
• Est. Priority Date: 05/30/2013
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Deshmukh, Unmesh Anil, Bishnoi, Sandeep, Srinivasan, Anand
• Primary Examiner(s): LEROUX, ETIENNE PIERRE
• Application Number:
  US13/906,162
• Publication Number:
  US 20140358959A1
• Time in Patent Office: 1,174 Days
• Field of Search: 707/2, 707/3, 707/5, 702/190, 709204-206
• US Class Current: 1/1
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries

Abstract

Techniques for managing value-based windows on relations are provided. In some examples, an input relation is generated. The input relation is a bounded set of data records related to an application. A continuous query that identifies the input relation may be received. Additionally, a configurable window operator associated with processing the input relation may be identified. Then, the continuous query may be executed based at least in part on the configurable window operator to generate an output relation. Further, in some instances, the data records of the output relation may be provided based at least in part on execution of the continuous query.

Claims

1. A computer-implemented method, comprising:

receiving a continuous input data stream related to an application;

generating an input relation from the continuous input data stream, the input relation being a bounded set of data records of the continuous input data stream;

storing the input relation as an external data source in a database of historical data;

receiving a continuous query that identifies the input relation and a range value window operator associated with the input relation;

executing the continuous query to generate an output relation, the continuous query executed by applying the range value window operator on an attribute of the input relation to generate the output relation, the attribute comprising a characteristic of an event associated with the input relation;

determining whether the event associated with the input relation occurs within a specified time range defined by the range value window operator;

inserting or removing the event with respect to the output relation based at least in part on the determination of whether the event associated with the input relation occurs within the specified time range; and

providing data records of the output relation, the output relation comprising at least the event when the event was inserted based at least in part on being within the specified range defined by the range value window operator.

2. The computer-implemented method of claim 1, wherein the input relation is generated based at least in part on information related to the application.

3. The computer-implemented method of claim 1, wherein the input relation is an external data source generated based at least in part on one or more archived relations related to the application.

4. The computer-implemented method of claim 1, wherein executing the query further comprises applying the range value window operator on a range window of the input relation to generate the output relation.

5. The computer-implemented method of claim 4, wherein providing the data records comprises displaying the output relation, wherein the output relation comprises a subset of the data records from the input relation whose attribute values lie within a specified range defined by the range value window operator.

6. The computer-implemented method of claim 1, further comprising identifying a current hour value window operator for processing the input relation and processing the data of the input relation based on the current hour value window operator to generate the output relation.

7. The computer-implemented method of claim 1, further comprising identifying a current period value window operator for processing the input relation and processing the data of the input relation based on the current period value operator to generate the output relation.

8. A non-transitory computer-readable memory storing a plurality of instructions executable by one or more processors, the plurality of instructions comprising:

instructions that cause the one or more processors to receive a continuous input data stream related to an application;

instructions that cause the one or more processors to generate an input relation from the continuous input data stream;

instructions that cause the one or more processors to store the input relation as an external data source in a database of historical data;

instructions that cause the one or more processors to receive a continuous query that identifies the input relation and a range value window operator associated with the input relation;

instructions that cause the one or more processors to execute the continuous query to generate an output relation, the continuous query executed by applying the range value window operator on an attribute of the input relation to generate the output relation, the attribute comprising a characteristic of an event associated with the input relation;

instructions that cause the one or more processors to determine whether the event associated with the input relation occurs within a specified time range defined by the range value window operator;

instructions that cause the one or more processors to determine inserting or removing the event with respect to the output relation based at least in part on the determination of whether the event associated with the input relation occurs within the specified time range; and

instructions that cause the one or more processors to provide data records of the output relation, the output relation comprising at least the event when the event was inserted based at least in part on being within the specified range defined by the range value window operator.

9. The computer-readable memory of claim 8, wherein the input relation is generated based at least in part on information related to the application.

10. The computer-readable memory of claim 8, wherein the input relation is an external data source generated based at least in part on one or more archived relations related to the application.

11. The computer-readable memory of claim 8, wherein the instructions that cause the one or more processors to execute the continuous query further comprise instructions for applying the range value window operator on a range window of the input relation to generate the output relation.

12. The computer-readable memory of claim 11, further comprising instructions that cause the one or more processors to display the output relation, wherein the output relation comprises a subset of the data records from the input relation whose attribute values lie within a specified range defined by the range value window operator.

13. The computer-readable memory of claim 8, further comprising instructions that cause the one or more processors to provide the data records of the output relation based at least in part on processing the data of the input relation.

14. A system, comprising:

a memory storing a plurality of instructions; and

one or more processors configured to access the memory, wherein the one or more processors are further configured to execute the plurality of instructions to at least;

generate an input relation from a continuous input data stream;

store the input relation as an external data source in a database of historical data;

receive a continuous query that identifies the input relation and a range value window operator associated with the input relation;

execute the continuous query to generate an output relation, the continuous query executed by applying the range value window operator on an attribute of the input relation to generate the output relation, the attribute comprising a characteristic of an event associated with the input relation;

determine whether the event associated with the input relation occurs within a specified time range defined by the range value window operator;

insert or remove the event with respect to the output relation based at least in part on the determination of whether the event associated with the input relation occurs within the specified time range; and

provide data records of the output relation, the output relation comprising at least the event when the event was inserted based at least in part on being within the specified range defined by the range value window operator.

15. The system of claim 14, wherein the one or more processors are further configured to identify a current period value window operator for processing the input relation and process the data of the input relation based on the current period value operator.

16. The system of claim 14, wherein the one or more processors are further configured to execute the plurality of instructions to provide data records of the output relation based at least in part on processing the data of the input relation.

17. The system of claim 14, wherein the one or more processors are further configured to display the output relation, wherein the output relation comprises a subset of the data records from the input relation whose attribute values lie within a specified range defined by the range window.