SUPPORT FOR A NEW INSERT STREAM (ISTREAM) OPERATION IN COMPLEX EVENT PROCESSING (CEP)

• US 20150156241A1
• Filed: 02/12/2015
• Published: 06/04/2015
• Est. Priority Date: 05/06/2011
• Status: Active Grant

• Current Assignee: Oracle International Corporation (Oracle Corporation)
• Original Assignee: Oracle International Corporation (Oracle Corporation)
• Inventors: Shukla, Vikram, Srinivasan, Anand
• Granted Patent: US 9,756,104 B2
• Time in Patent Office: Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: H04L 43/08 Monitoring or testing based on specific metrics, e.g. QoS, energy consumption or environmental parameters
• CPC Class Codes: H04L 47/28 in relation to timing considerations
• CPC Class Codes: H04L 65/762 at the source reformatting of additional data in video distribution servers H04N21/2355

Abstract

One embodiment of the invention includes a method of processing streaming data. The method includes initializing a stream of data and setting a time interval to apply to the stream of data. The time interval comprises a window for analyzing the data within the stream of data. The method further includes identifying one or more columns within the stream of data, designating one or more of the columns to be monitored for differences within the data over the time interval, and monitoring the designated columns over the time interval. Further, the method includes determining that at least one value from at least one of the designated columns has changed and in response to at least one value changing, outputting the changed values from the designated columns.

Claims

1. A method of processing streaming data, the method comprising:

initializing, by a computer processor, a stream of data for a continuous query logic (CQL) operation;

identifying, by the computer processor, one or more columns within the stream of data;

designating, in the CQL operation, one or more of the columns to be monitored for differences in data within the columns over a time interval by applying a SELECT list expressions to a subset of the stream of data, wherein the one or more designated columns are columns of interest;

applying a relation-to-stream operator to the one or more designated columns;

monitoring, by the computer processor, the data within the designated columns over the time interval;

determining, by the computer processor, that at least one value from at least one of the one or more designated columns has changed based on applying the relation-to stream operator to the one or more designated columns; and

in response to at least one value changing, outputting the changed values from the designated columns that occur within the time interval using the CQL operation.

2. The method of claim 1, further comprising setting the time interval of the CQL operation to apply to the stream of data, wherein the time interval comprises a window for analyzing the data within the designated columns.

3. The method of claim 1, further comprising, determining, by the computer processor, that no values from at least one of the designated columns have changed over the time interval.

4. The method of claim 3, in response to determining that no values from least one of the designated columns have changed, not outputting by the computer processor, the values from at least one of the designated columns.

5. The method of claim 1, further comprising continuing to receive the data associated with the designated columns for a next time interval of the CQL operation.

6. The method of claim 5, wherein the data associated with the designated columns for the next time interval is received substantially in real-time.

7. The method of claim 1, wherein the one or more columns are included in one or more tables constructed from the stream of data over the time interval.

8. The method of claim 1, wherein the stream of data comprises a complex event processing (CEP) data stream.

9. A computer-readable storage medium having stored thereon instructions for causing at least one computer system to detect policy violations for an organization, the instructions comprising:

instructions that cause the at least one computer system to initialize a stream of data for a continuous query logic (CQL) operation;

instructions that cause the at least one computer system to identify one or more columns within the stream of data;

instructions that cause the at least one computer system to designate in the CQL operation, one or more of the columns to be monitored for differences in data within the columns over a time interval by applying a SELECT list expressions to a subset of the stream of data, wherein the one or more designated columns are columns of interest;

instructions that cause the at least one computer system to apply a relation-to-stream operator to the one or more designated columns;

instructions that cause the at least one computer system to monitor the data within the designated columns over the time interval;

instructions that cause the at least one computer system to determine that at least one value from at least one of the one or more designated columns has changed based on applying the relation-to-stream operator; and

in response to at least one value changing, instructions that cause the at least one computer system to output the changed values from the designated columns that occur within the time interval using the CQL operation.

10. The computer-readable storage medium of claim 9, wherein the instructions further comprise instructions to set the time interval of the CQL operation to apply to the stream of data, wherein the time interval comprises a window for analyzing the data within the designated columns.

11. The computer-readable storage medium of claim 9, wherein the instructions further comprise instructions to determine that no values from at least one of the designated columns have changed over the time interval.

12. The computer-readable storage medium of claim 11, wherein the instructions further comprise instructions to not output the values from at least one of the designated columns in response to the instructions to determine that no values from at least one of the designated columns have changed over the time interval.

13. The computer-readable storage medium of claim 9, wherein the instructions further comprise instructions to receive the data associated with the designated columns for a next time interval of the CQL operation.

14. The computer-readable storage medium of claim 13, wherein the data associated with the designated columns for the next time interval is received substantially in real-time.

15. The computer-readable storage medium of claim 9, wherein the stream of data comprises a complex event processing (CEP) data stream.

16. A system for processing streaming data, comprising:

one or more computing devices comprising at least one processor configured to execute computer executable instructions to collectively at least;

initialize a stream of data for a continuous query logic (CQL) operation;

identify one or more columns within the stream of data;

designate in the CQL operation, a subset of columns to be monitored for differences in data within the one or more columns over a time interval by applying a SELECT list expressions to a subset of the stream of data, wherein the one or more designated columns are columns of interest;

apply a relation-to-stream operator to the one or more designated columns;

monitor the data within the designated columns over the time interval;

determine that at least one value from at least one of the one or more designated columns has changed based on applying the relation-to stream operator to the one or more designated columns;

in response to at least one value changing, outputting the changed values from the designated columns that occur within the time interval using the CQL operation;

determine that no values from at least one of the designated columns have changed over the time interval; and

in response to determining that no values from least one of the designated columns have changed, not outputting the values from at least one of the designated columns.

17. The system of claim 16, wherein the one or more computing devices are collectively operable to set the time interval of the CQL operation to apply to the stream of data, wherein the time interval comprises a window for analyzing the data within the designated columns.

18. The system of claim 16, wherein the one or more computing devices are further collectively operable to receive the data associated with the designated columns for the next time interval substantially in real-time.

19. The system of claim 16, wherein the one or more columns are included in one or more tables constructed from the stream of data over the time interval.

20. The system of claim 16, wherein the stream of data comprises a complex event processing (CEP) data stream.