对复杂事件处理（CEP）中的新插入流（ISTREAM）操作的支持

摘要

本发明的一个实施例包括处理流式数据的方法。该方法包括初始化数据流，以及设置要应用于数据流的时间间隔。时间间隔包括用于分析数据流内的数据的窗口。该方法还包括标识数据流内的一个或多个列、指定要被监测在所述时间间隔内所述数据内的差异的所述列中的一个或多个，以及监测在所述时间间隔内所指定的列。进一步地，该方法包括判断所指定的列中的至少一个的至少一个值已经变化，响应于至少一个值变化，从所指定的列输出变化的值。

主权项

一种处理流式数据的方法，所述方法包括：初始化数据流；设置要应用于所述数据流的时间间隔，其中，所述时间间隔包括用于分析所述数据流内的数据的窗口；标识所述数据流内的一个或多个列；指定所述列中的一个或多个以监测在所述时间间隔内所述数据内的差异；在所述时间间隔内监测所指定的列；判断来自所指定的列中的至少一个的至少一个值已经变化；以及响应于至少一个值变化，从所指定的列输出变化的值。