SPATIAL DATA CARTRIDGE FOR EVENT PROCESSING SYSTEMS

• US 20110161328A1
• Filed: 11/18/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: Park, Hoyong, Srinivasan, Anand, de Castro Alves, Alexandre, Deshmukh, Unmesh
• Granted Patent: US 9,430,494 B2
• Time in Patent Office: Days
• US Class Current: 707/743
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/29 Geographical information databases

Abstract

Techniques for extending the capabilities of an event processing system to support the processing of spatial data. In one set of embodiments, this extensibility can be provided via a plug-in extension component referred to herein as a spatial data cartridge. The spatial data cartridge can enable the event processing system to support spatial data types (e.g., point, polygon, etc.) and various operations related to such data types (e.g., proximity determinations, overlap determinations, etc.). The spatial data cartridge can also define an indexing scheme that can be integrated with the capabilities of the event processing system to support the indexing of spatial data. Using the spatial data cartridge, the event processing system can operate on spatial data even if spatial data formats are not natively supported by the system.

Claims

1. A system comprising:

a storage component configured to store a spatial data cartridge including metadata pertaining to a spatial function and code that implements the spatial function, the spatial function being configured to determine a topological relationship between first spatial data and second spatial data; and

a processor configured to;

receive a query referencing the spatial function, the query being adapted to process one or more data streams;

compile the query based on the metadata included in spatial data cartridge; and

execute the query based on the code included in the spatial data cartridge.

2. The system of claim 1 wherein the system is an event processing system.

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

4. The system of claim 1 wherein the query includes a link definition that specifies the spatial function and the spatial data cartridge, and wherein the processor is configured to identify the spatial data cartridge based on the link definition.

5. The system of claim 1 wherein the spatial function is selected from a group consisting of:

contains, inside, withindistance, overlaps, touch, covers, and coveredby.

6. The system of claim 1 wherein the spatial data cartridge further includes metadata pertaining to one or more spatial data types and one or more spatial indexes.

7. The system of claim 6 wherein the one or more spatial data types are selected from a group consisting of:

point, curve, polygon, and solid.

8. The system of claim 1 wherein compiling the query comprises:

retrieving the metadata pertaining to the spatial function from the spatial data cartridge;

performing semantic analysis of the query based on the metadata; and

generating instructions for executing the query.

9. The system of claim 1 wherein executing the query comprises executing the code that implements the spatial function in the spatial data cartridge.

10. The system of claim 9 wherein executing the code that implements the spatial function comprises:

performing a first filter operation with respect to data in a first spatial data stream and data in a second spatial data stream, the first filter operation returning a superset of an exact result set for the spatial function; and

performing a second filter operation with respect to the superset, the second filter operation returning the exact result set for the spatial function.

11. The system of claim 10 wherein performing the first filter operation comprises:

comparing geometric approximations of the data in the first spatial data stream and the data in the second spatial data stream; and

determining likely topological relationships between the data in the first spatial data stream and the data in the second spatial data stream based on the comparing.

12. The system of claim 10 wherein performing the second filter operation comprises:

comparing exact geometries of the data in the first spatial data stream and the data in the second spatial data stream; and

determining exact topological relationships between the data in the first spatial data stream and the data in the second spatial data stream based on the comparing.

13. The system of claim 10 wherein performing the first filter operation comprises performing an index scan of a spatial index created for the first spatial data stream or the second spatial data stream.

14. The system of claim 1 wherein the storage component is further configured to store spatial context information, and wherein executing the query is further based on the spatial context information.

15. The system of claim 14 wherein the spatial context information identifies a geometric coordinate system.

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 register a spatial data cartridge including metadata pertaining to a spatial function and code that implements the spatial function, the spatial function being configured to determine a topological relationship between first spatial data and second spatial data;

instructions that cause the processor to receive a query referencing the spatial function, the query being adapted to process one or more data streams;

instructions that cause the processor to compile the query based on the metadata included in spatial data cartridge; and

instructions that cause the processor to execute the query based on the code included in the spatial data cartridge.

17. The non-transitory computer-readable storage medium of claim 16 wherein the instructions that cause the processor to execute the query comprises instructions that cause the processor to execute the code that implements the spatial function in the spatial data cartridge.

18. The non-transitory computer-readable storage medium of claim 17 wherein the instructions that cause the processor to execute the code that implements the spatial function comprises:

instructions that cause the processor to perform a first filter operation with respect to data in a first spatial data stream and data in a second spatial data stream, the first filter operation returning a superset of an exact result set for the spatial function; and

instructions that cause the processor to perform a second filter operation with respect to the superset, the second filter operation returning the exact result set for the spatial function.

19. The non-transitory computer-readable storage medium of claim 16 wherein the instructions further comprise instructions that cause the processor to store spatial context information, and wherein executing the query is further based on the spatial context information.

20. A method comprising:

registering, by a computer system, a spatial data cartridge including metadata pertaining to a spatial function and code that implements the spatial function, the spatial function being configured to determine a topological relationship between first spatial data and second spatial data;

receiving, by the computer system, a query referencing the spatial function, the query being adapted to process one or more data streams;

compiling, by the computer system, the query based on the metadata included in spatial data cartridge; and

executing, by the computer system, the query based on the code included in the spatial data cartridge.