PROCESSING EVENTS FOR CONTINUOUS QUERIES ON ARCHIVED RELATIONS

• US 20140095483A1
• 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: Deshmukh, Unmesh Anil, Srinivasan, Anand, Shukla, Vikram, Toillion, Jeffrey
• Granted Patent: US 9,990,401 B2
• Time in Patent Office: Days
• US Class Current: 707/722
• 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 counting event changes with archived relations are provided. In some examples, a query that identifies at least a data object may be identified. Additionally, the query may be evaluated against historical data associated with the data object. Additionally, in some instances, a listening service may be registered with the data object. Further, the query may be evaluated based at least in part on the data object and the historical data.

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;

identify a query that identifies at least a data object;

evaluate the query against historical data associated with the data object;

register a listening service with the data object; and

evaluate the query based at least in part on the data object and the historical data.

2. The system of claim 1, wherein the listening service is registered with the data object prior to evaluating the query against the historical data.

3. The system of claim 2, wherein changes identified by the listening service are processed after completion of evaluation of the query against the historical data.

4. The system of claim 1, wherein the processors are further configured to execute the plurality of instructions to at least receive a transaction identifier for at least a change identified by the listening service.

5. The system of claim 4, wherein the transaction identifier comprises a monotonically increasing integer that increases for each change associated with the data object.

6. The system of claim 4, wherein the processors are further configured to execute the plurality of instructions to at least:

compare the received transaction identifier with a highest transaction identifier associated with the historical data; and

process the change identified by the listening service only when the received transaction identifier is greater than the highest transaction identifier associated with the historical data.

7. The system of claim 1, wherein the data object manages a stream of incoming business event data.

8. The system of claim 7, wherein the query comprises a continuous query configured to process data of the stream via the data object.

9. The system of claim 8, wherein the historical data comprises business event data from the data stream at a time before initializing the query.

10. The system of claim 1, wherein the historical data associated with the data object is stored in a storage system other than the data object.

11. The system of claim 10, wherein the evaluation of the query against the historical data associated with the data object is configured to initialize a query engine of the system.

12. 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 receive a continuous query that identifies at least one of a data object associated with a stream of business event data or historical data associated with the stream of business event data;

instructions that cause the one or more processors to register a listening service with the data object;

instructions that cause the one or more processors to evaluate the continuous query against the historical data associated with the data object after registration of the listening service with the data object;

instructions that cause the one or more processors to process changes identified by the listening service after completion of the evaluation of the continuous query against the historical data; and

instructions that cause the one or more processors to evaluate the continuous query based at least in part on the data object and the processed changes identified by the listening service.

13. The computer-readable memory of claim 12, wherein the plurality of instructions further comprise instructions that cause the one or more processors to receive a transaction identifier for at least a change identified by the listening service.

14. The computer-readable memory of claim 13, wherein the transaction identifier comprises a monotonically increasing integer that increases for each change associated with the data object.

15. The computer-implemented method of claim 13, wherein the plurality of instructions further comprise instructions that cause the one or more processors to compare the received transaction identifier with a highest transaction identifier associated with the historical data.

16. The computer-implemented method of claim 15, wherein the plurality of instructions further comprise instructions that cause the one or more processors to process the change identified by the listening service only when the received transaction identifier is greater than the highest transaction identifier associated with the historical data.

17. A computer-implemented method, comprising:

receiving a continuous query that identifies at least one of a data object associated with a stream of business event data or historical data associated with the stream of business event data;

registering a listening service with the data object;

evaluating the continuous query against the historical data associated with the data object;

receiving a transaction identifier for at least a change identified by the listening service;

comparing the received transaction identifier with a highest transaction identifier associated with the historical data;

processing the change identified by the listening service when the received transaction identifier is greater than the highest transaction identifier associated with the historical data; and

evaluating the continuous query based at least in part on the data object.

20. The computer-implemented method of claim 17, further comprising not processing the change identified by the listening service when the received transaction identifier is less than the highest transaction identifier associated with the historical data or equal to the highest transaction identifier associated with the historical data.

18. The computer-implemented method of 17, wherein the continuous query is evaluated against the historical data after registration of the listening service with the data object.

19. The computer-implemented method of 18, further comprising processing the changes identified by the listening service after completion of the evaluation of the continuous query against the historical data.