VALUE BASED WINDOWS ON RELATIONS IN CONTINUOUS DATA STREAMS

• US 20140358959A1
• Filed: 05/30/2013
• Published: 12/04/2014
• Est. Priority Date: 05/30/2013
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: BISHNOI, Sandeep, SRINIVASAN, Anand, DESHMUKH, Unmesh Anil
• Granted Patent: US 9,418,113 B2
• Time in Patent Office: Days
• US Class Current: 707/769
• 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:

generating an input relation, the input relation being a bounded set of data records related to an application;

receiving a continuous query that identifies the input relation;

identifying a configurable window operator associated with processing the input relation;

executing the continuous query based at least in part on the configurable window operator to generate an output relation; and

providing data records of the output relation based at least in part on execution of the continuous query.

2. The computer-implemented method of claim 1, wherein the input relation is an external data source generated based at least in part on an incoming continuous input data stream 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 information related to the application stored in a database of historical data.

4. 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.

5. The computer-implemented method of claim 1, wherein the configurable window operator is a generic value window operator defined over the input relation, and wherein executing the continuous query comprises applying the generic value window operator on an attribute in the input relation to generate the output relation.

6. The computer-implemented method of claim 1, wherein the configurable window operator is a current hour value window operator defined over the input relation, and wherein executing the continuous query comprises applying the current hour value window operator on an attribute in the input relation to generate the output relation.

7. The computer-implemented method of claim 1, wherein the configurable window operator is a current period value window operator defined over the input relation, and wherein executing the continuous query comprises applying the current period value window operator on an attribute in the input relation to generate the output relation.

8. The computer-implemented method of claim 1, 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 configurable window operator.

9. 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 generate an input relation;

instructions that cause the one or more processors to identify a query configured to process the input relation;

instructions that cause the one or more processors to identify a configurable window operator associated with processing the input relation; and

instructions that cause the one or more processors to execute the query based at least in part on the configurable window operator to generate an output relation.

10. The computer-readable memory of claim 9, wherein the input relation is an external data source generated based at least in part on an incoming continuous input data stream related to the application.

11. The computer-readable memory of claim 9, wherein the input relation is an external data source generated based at least in part on information related to the application stored in a database of historical data.

12. The computer-readable memory of claim 9, 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.

13. The computer-readable memory of claim 9, wherein the configurable window operator is a generic value window operator defined over the input relation, and wherein executing the continuous query comprises applying the generic value window operator on an attribute in the input relation to generate the output relation.

14. The computer-readable memory of claim 9, further comprising instructions to provide data records of the output relation based at least in part on execution of the continuous query.

15. The computer-readable memory of claim 14, further comprising instructions 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 configurable window operator.

16. 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;

identify a query configured to process the input relation;

identify a configurable window operator associated with processing the input relation; and

execute the query based at least in part on the configurable window operator to generate an output relation.

17. The system of claim 16, wherein the input relation is an external data source generated based at least in part on an incoming continuous input data stream related to the application.

18. The system of claim 16, wherein the configurable window operator is a current period value window operator defined over the input relation, and wherein executing the continuous query comprises applying the current period value window operator on an attribute in the input relation to generate the output relation.

19. The system of claim 16, 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 execution of the continuous query.

20. The system of claim 16, 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 configurable window operator.