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

摘要

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.

主权项

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.