SUPPORT FOR A NEW INSERT STREAM (ISTREAM) OPERATION IN COMPLEX EVENT PROCESSING (CEP)
First Claim
1. A method of processing streaming data, the method comprising:
- initializing a stream of data;
setting a time interval to apply to the stream of data, wherein the time interval comprises a window for analyzing the data within the stream of data;
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;
monitoring the designated columns over the time interval;
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.
1 Assignment
0 Petitions
Accused Products
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.
-
Citations
20 Claims
-
1. A method of processing streaming data, the method comprising:
-
initializing a stream of data; setting a time interval to apply to the stream of data, wherein the time interval comprises a window for analyzing the data within the stream of data; 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; monitoring the designated columns over the time interval; 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. - View Dependent Claims (2, 3, 4, 5, 6, 7, 20)
-
-
8. A non-transitory computer-readable medium for processing streaming data having sets of instructions stored thereon which, when executed by a computer, cause the computer to:
-
convert relational data into streaming data by applying an istream operator; determine one or more segments within the streaming data as applied by a bounding constraint, wherein the bounding constraint designates segment boundaries; identify a column from the data stream; select the identified column over the determined segment; select a column to monitor changes in the data within the column over the determined segment; execute a multiset istream operation of the selected column over the determined segment as applied to the monitored column; and output the resulting data from the mutiset istream operation. - View Dependent Claims (9, 10, 11, 12)
-
-
13. A system for processing streaming data, the system comprising:
-
a storage memory having sets of instructions stored thereon; and a processor coupled with the storage memory, wherein the sets of instructions when executed by the processor, cause the processor to; initialize a stream of data; set a time interval to apply to the stream of data, wherein the time interval comprises a window for analyzing the data within the stream of data; identify one or more columns within the stream of data; designate one or more of the columns to be monitored for differences within the data over the time interval; monitor the designated columns over the time interval; determine that at least one value from at least one of the designated columns has changed; and in response to at least one value changing, output the changed values from the designated columns. - View Dependent Claims (14, 15, 16, 17, 18, 19)
-
Specification