用于查询数据流的系统和方法

摘要

提供了一种用于查询数据流的方法。所述方法包括接收基于规定数据流和窗口的查询的查询计划。所述方法进一步包括在所述窗口期间从所述数据流接收一个或多个流元素。此外，所述方法包括通过在逐个元组的基础上将所述一个或多个流元素从在所述查询计划的叶处的扫描操作符传递到所述查询计划的上层来对所述一个或多个流元素应用所述查询。所述方法还包括基于所述一个或多个流元素来提交所述查询的结果。

主权项

一种用于查询数据流的方法，包括：接收基于规定所述数据流和窗口的查询的查询计划；在所述窗口期间从所述数据流接收一个或多个流元素；通过在逐个元组的基础上将所述一个或多个流元素从在所述查询计划的叶处的扫描操作符传递到所述查询计划的上层来对所述一个或多个流元素应用所述查询；基于所述一个或多个流元素来提交所述查询的结果；基于在所述查询中规定的用户定义函数来启动事务；以及在所述事务期间执行与多个窗口相对应的多个周期，其中所述多个窗口包括所述窗口，并且其中，所述周期中的每一个都包括：接收所述一个或多个流元素；对所述一个或多个流元素应用所述查询；并且提交所述结果。