MECHANISM TO CHAIN CONTINUOUS QUERIES

• US 20140095540A1
• Filed: 03/14/2013
• Published: 04/03/2014
• Est. Priority Date: 09/28/2012
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Hsiao, Eric, Park, Hoyong, Srinivasan, Anand
• Granted Patent: US 9,946,756 B2
• Time in Patent Office: Days
• US Class Current: 707/774
• CPC Class Codes: B29D 2030/0682 Inner liners tubeless tyres with impervious liner or coating on the tyre B60C5/14
• CPC Class Codes: B29D 30/0681 Parts of pneumatic tyres; accessories, auxiliary operations
• CPC Class Codes: B32B 27/08 of synthetic resin
• CPC Class Codes: B32B 27/34 comprising polyamides
• CPC Class Codes: B60C 1/0008 Compositions of the inner liner
• CPC Class Codes: B60C 5/14 with impervious liner or coating on the inner wall of the tyre
• CPC Class Codes: G06F 16/242 Query formulation
• CPC Class Codes: G06F 16/245 Query processing
• CPC Class Codes: G06F 16/2453 Query optimisation
• CPC Class Codes: G06F 16/24535 of sub-queries or views
• CPC Class Codes: G06F 16/24539 using cached or materialised query results
• CPC Class Codes: G06F 16/2455 Query execution
• CPC Class Codes: G06F 16/24553 of query operations
• CPC Class Codes: G06F 16/2456 Join operations
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/2474 Sequence data queries, e.g. querying versioned data
• CPC Class Codes: G06F 16/2477 Temporal data queries
• CPC Class Codes: G06F 16/248 Presentation of query results
• CPC Class Codes: G06F 16/25 Integrating or interfacing systems involving database management systems
• CPC Class Codes: G06F 16/313 Selection or weighting of terms for indexing
• CPC Class Codes: G06F 16/9024 : Graphs; Linked lists G06F16/9027 takes precedence
• CPC Class Codes: G06F 16/951 : Indexing; Web crawling techniques

Abstract

Techniques for implementing mechanisms for chaining continuous queries are provided. In some examples, results of a first continuous query may be stored in a data object. For example, the first continuous query may be configured to process business event data and store the results in the data object. Additionally, a second continuous query may then be processed based at least in part on the results stored in the data object.

Claims

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

store results of a first continuous query in a data object, the first continuous query configured to process business event data; and

process a second continuous query based at least in part on the results stored in the data object.

2. The system of claim 1, wherein the one or more processors are further configured to execute the plurality of instructions to at least audit the results stored in the data object.

3. The system of claim 1, wherein the data object is configured as a stream data object.

4. The system of claim 3, wherein the stream data object is configured to only perform “

insert”

actions.

5. The system of claim 1, wherein the one or more processors are further configured to execute the plurality of instructions to at least map the data object to a visualization.

6. The system of claim 5, wherein the one or more processors are further configured to execute the plurality of instructions to at least prepare the visualization for display by a user interface of a user associated with the business event data.

7. The system of claim 1, wherein the results of the first continuous query are stored in the data object for at least a first period of time.

8. The system of claim 7, wherein the second continuous query is processed prior to completion of the first period of time.

9. The system of claim 7, wherein the first period of time is determined based at least in part on performance criteria.

10. The system of claim 1, wherein the one or more processors are further configured to execute the plurality of instructions to at least enable modification of the data object.

11. A 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 initialize a first continuous query on business event data associated with a user to collect a first result during a time interval;

instructions that cause the one or more processors to store the first result in memory as a data object;

instructions that cause the one or more processors to submit, based at least in part on receipt of a trigger, the first result of the data object to a second continuous query; and

instructions that cause the one or more processors to provide an alert to the user based at least in part on a second result from the second continuous query.

12. The computer-readable memory of claim 11, wherein the business event data associated with the user corresponds with a stream or an archived relation associated with the stream.

13. The computer-readable memory of claim 11, wherein the first result is collected based on a moving window.

14. The computer-implemented method of claim 13, wherein at least one of the moving window or the time interval is determined by the user.

15. The computer-implemented method of claim 11, wherein the trigger indicates a change in the first result stored in the data object.

16. A computer-implemented method, comprising:

implementing a first continuous query on business event data associated with a user to collect a first result during a time interval;

storing the first result in memory as a data object;

providing, based at least in part on receipt of a trigger, the first result of the data object to a second continuous query;

providing, for display by a user interface of the user, a mapping of at least one of the first result or the second result to a visualization; and

providing an alert to the user based at least in part on a second result from the second continuous query.

19. The computer-implemented method of claim 16, wherein the mapping is configured to provide a real-time visualization of changes of at least one of the first result or the second result.

20. The computer-implemented method of claim 16, wherein the data object is configured to only process “

insert”

instructions.

17. The computer-implemented method of 16, wherein the first continuous query is configured to receive data from a stream or an archived relation.

18. The computer-implemented method of 17, the archived relation comprises an unordered, time-varying set of tuples associated with the stream.