Addition and processing of continuous SQL queries in a streaming relational database management system

摘要

Systems, methods, and media are disclosed herein that can be embodied in a traditional Relational Database Management System (RDBMS) in order to transform it into a Streaming Relational Database Management System (SRDBMS). An SRDBMS may provide functionality such as to manage and populate streams, tables, and archived stream histories and support the evaluation of continuous queries on streams and tables. Both continuous and snapshot queries support the full spectrum of the industry standard, widely used, Structured Query Language. The present technology can support a high number of concurrent continuous queries using a scalable and efficient shared query evaluation scheme, support on-the-fly addition of continuous queries into a mechanism that implements the shared evaluation scheme, reuse RDBMS modules such as relational operators and expression evaluators, and visualize results of continuous queries in real time.

主权项

1. A method for managing a data stream, comprising:
a streaming relational database management server receiving a continuous query, wherein the continuous query is a request for an unbounded set of records over time; in response to receiving the continuous query, the streaming relational database management server generating a first stream-to-relation operator; the first stream-to-relation operator returning, to a second stream-to-relation operator, an unbounded set of windows over time, wherein a first window comprises a tuple comprising: a first control information that indicates a first edge, the first edge belonging to the first window; a second control information that indicates a second edge, the second edge belonging to a second window; using the second stream-to-relation operator, determining the first edge for the first window based on the first control information; using the second stream-to-relation operator, determining the second edge for the second window based on the second control information; based, at least in part, on the second control information, the second stream-to-relation operator returning a window before receiving the second window; wherein the method is performed by one or more computing devices.