EXTENSIBLE LANGUAGE FRAMEWORK USING DATA CARTRIDGES

• US 20110161356A1
• 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 9,058,360 B2
• Time in Patent Office: Days
• US Class Current: 707/769
• 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. In one set of embodiments, the data cartridge framework described herein can enable an event processing system to support one or more extension languages that are distinct from the native event processing language supported by the system. For example, certain “extension language” data cartridges can be provided that enable an event processing system to support complex data types and associated methods/operations that are common in object-oriented languages, but are not common in event processing languages. In these embodiments, an event processing system can access an extension language data cartridge to compile and execute queries that are written using a combination of the system'"'"'s native event processing language and the extension language.

Claims

1. A method comprising:

receiving, by a computer system, a query expressed in an event processing language, the query including a reference to a complex type implemented in another language distinct from the event processing language; and

compiling, by the computer system, the query by;

retrieving metadata pertaining to the complex type from information stored in a data cartridge for the complex type; and

generating, based on the metadata, executable instructions for executing the query.

2. The method of claim 1 wherein the event processing language is Continuous Query Language (CQL).

3. The method of claim 1 wherein the another language distinct from the event processing language is an object-oriented language.

4. The method of claim 1 wherein the another language distinct from the event processing language is Java, and wherein the complex type is a Java class.

5. The method of claim 1 wherein the query is configured for processing one or more events received via one or more event streams.

6. The method of claim 5 wherein retrieving the metadata pertaining to the complex type comprises:

determining whether the complex type corresponds to an attribute in any of the one or more event streams;

if the complex type does not correspond to an attribute in any of the event streams;

determining whether the complex type corresponds to a type defined in the event processing language; and

if the complex type does not correspond to a type defined in the event processing language, retrieving the metadata pertaining to the complex type from the data cartridge.

7. The method of claim 1 wherein the reference to the complex type includes an invocation of a method associated with the complex type, and wherein the invocation includes a name of the method and one or more parameters.

8. The method of claim 7 wherein the method associated with the complex type is a constructor for the complex type.

9. The method of claim 7 wherein compiling the query further comprises:

analyzing the metadata pertaining to the complex type to determine whether the metadata includes a method signature that matches the name of the method and the one or more parameters; and

if the metadata includes a method signature that matches the name of the method and the one or more parameters;

retrieving, from the data cartridge, a reference to a function corresponding to the method associated with the complex type, the function'"'"'s implementation being included in the information stored by the data cartridge for the complex type; and

including the reference to the function in the executable instructions for executing the query.

10. The method of claim 9 wherein analyzing the metadata pertaining to the complex type to determine whether the metadata includes a method signature that matches the name of the method and the one or more parameters comprises:

determining native data types for the one or more parameters, the native data types being native to the event processing system;

mapping the native data types to corresponding data types in the another language distinct from the event processing language; and

matching the corresponding data types to data types specified in the method signature.

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

12. The method of claim 11 wherein executing the query comprises:

invoking the reference to the function; and

executing the implementation of the function included in the information stored by the data cartridge for the complex type.

13. A system comprising:

a processor configured to;

receive a query expressed in an event processing language, the query including a reference to a complex type implemented in another language distinct from the event processing language; and

compile the query by;

retrieving metadata pertaining to the complex type from information stored in a data cartridge for the complex type; and

generating, based on the metadata, executable instructions for executing the query.

14. The system of claim 13 wherein the reference to the complex type includes an invocation of a method associated with the complex type, and wherein the invocation includes a name of the method and one or more parameters.

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

analyzing the metadata pertaining to the complex type to determine whether the metadata includes a method signature that matches the name of the method and the one or more parameters; and

if the metadata includes a method signature that matches the name of the method and the one or more parameters;

retrieving, from the data cartridge, a reference to a function corresponding to the method associated with the complex type, the function'"'"'s implementation being included in the information stored by the data cartridge for the complex type; and

including the reference to the function in the executable instructions for executing the query.

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

17. 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 expressed in an event processing language, the query including a reference to a complex type implemented in another language distinct from the event processing language; and

instructions that cause the processor to compile the query by;

retrieving metadata pertaining to the complex type from information stored in a data cartridge for the complex type; and

generating, based on the metadata, executable instructions for executing the query.

18. The non-transitory computer-readable storage medium of claim 17 wherein the reference to the complex type includes an invocation of a method associated with the complex type, and wherein the invocation includes a name of the method and one or more parameters.

19. The non-transitory computer-readable storage medium of claim 18 wherein compiling the query further comprises:

analyzing the metadata pertaining to the complex type to determine whether the metadata includes a method signature that matches the name of the method and the one or more parameters; and

if the metadata includes a method signature that matches the name of the method and the one or more parameters;

retrieving, from the data cartridge, a reference to a function corresponding to the method associated with the complex type, the function'"'"'s implementation being included in the information stored by the data cartridge for the complex type; and

including the reference to the function in the executable instructions for executing the query.

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