EXTENSIBILITY PLATFORM USING DATA CARTRIDGES

• US 20110161321A1
• Filed: 11/30/2010
• Published: 06/30/2011
• Est. Priority Date: 12/28/2009
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Mishra, Shailendra, Park, Hoyong, Srinivasan, Anand, de Castro Alves, Alexandre
• Granted Patent: US 8,447,744 B2
• Time in Patent Office: Days
• US Class Current: 707/736
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/25 Integrating or interfacing systems involving database management systems

Abstract

A framework for extending the capabilities of an event processing system using one or more plug-in components referred to herein as data cartridges. Generally speaking, a data cartridge is a self-contained unit of data that can be registered with an event processing system and can store information pertaining to one or more objects (referred to herein as extensible objects) that are not natively supported by the system. Examples of such extensible objects can include data types, functions, indexes, data sources, and others. By interacting with a data cartridge, an event processing system can compile and execute queries that reference extensible objects defined in the data cartridge, thereby extending the system beyond its native capabilities.

Claims

1. A method comprising:

receiving, by a computer system, a query configured for processing events received via one or more event streams; and

compiling, by the computer system, the query by;

retrieving metadata pertaining to an extensible object from information stored by a data cartridge for the extensible object; and

generating, based on the metadata, executable instructions for executing the query, the executable instructions including a call-out instruction to a function whose implementation is included in the information stored by the data cartridge for the extensible object.

2. The method of claim 1 wherein the query is a Continuous Query Language (CQL) query.

3. The method of claim 1 wherein the query includes a link definition identifying the extensible object and a source of metadata for the extensible object, and wherein compiling the query further comprises identifying the data cartridge based upon the link definition.

4. The method of claim 3 wherein the data cartridge is registered with the computer system in a registry, and wherein identifying the data cartridge based upon the link definition comprises searching the registry.

5. The method of claim 1 further comprising executing the query using the executable instructions to process the events received via the one or more event streams.

6. The method of claim 5 wherein executing the query comprises:

invoking the call-out instruction to the function; and

executing the implementation of the function included in the information stored by the data cartridge for the extensible object.

7. The method of claim 6 wherein executing the implementation of the function comprises:

accessing application context information stored by the data cartridge; and

executing the implementation of the function based on the application context information.

8. The method of claim 1 wherein the extensible object is selected from a group consisting of:

a data type, a function, an index, and a data source.

9. The method of claim 1 wherein compiling the query further comprises performing semantic analysis of the query using the metadata.

10. The method of claim 1 wherein the computer system cannot natively compile queries referencing the extensible object without accessing the data cartridge.

11. A system comprising:

a processor configured to;

receive a query configured for processing events received via one or more event streams; and

compile the query by;

retrieving metadata pertaining to an extensible object from information stored by a data cartridge for the extensible object; and

generating, based on the metadata, executable instructions for executing the query, the executable instructions including a call-out instruction to a function whose implementation is included in the information stored by the data cartridge for the extensible object.

12. The system of claim 11 wherein the system is an event processing system.

13. The system of claim 11 wherein the query is a Continuous Query Language (CQL) query.

14. The system of claim 11 wherein the processor is further configured to execute the query using the executable instructions to process the events received via the one or more event streams.

15. The system of claim 14 wherein executing the query comprises:

invoking the call-out instruction to the function; and

executing the implementation of the function included in the information stored by the data cartridge for the extensible object.

16. A non-transitory computer-readable storage medium having stored thereon instructions executable by a processor, the instructions comprising:

instructions that cause the processor to receive a query configured for processing events received via one or more event streams; and

instructions that cause the processor to compile the query by;

retrieving metadata pertaining to an extensible object from information stored by a data cartridge for the extensible object; and

generating, based on the metadata, executable instructions for executing the query, the executable instructions including a call-out instruction to a function whose implementation is included in the information stored by the data cartridge for the extensible object.

17. The non-transitory computer-readable storage medium of claim 16 wherein the query is a Continuous Query Language (CQL) query.

18. The non-transitory computer-readable storage medium of claim 16 wherein the instructions further comprise instructions that cause the processor to execute the query using the executable instructions to process the events received via the one or more event streams.

19. The non-transitory computer-readable storage medium of claim 18 wherein the instructions that cause the processor to execute the query comprise:

instructions that cause the processor to invoke the call-out instruction to the function; and

instructions that cause the processor to execute the implementation of the function included in the information stored by the data cartridge for the extensible object.