Apparatus and method for efficiently processing multiple continuous aggregate queries in data streams

摘要

An apparatus and a method for efficiently processing multiple continuous aggregate queries in data streams are provided. The apparatus includes a first operation result sharing unit configured to generate a common window including first aggregate areas, and store a first operation result of each of the multiple continuous aggregate queries for each of the first aggregate areas. The apparatus further includes a second operation result sharing unit configured to determine a second aggregate area including at least one of the first aggregate areas, and store a second operation result of each of the multiple continuous aggregate queries for the second aggregate area. The apparatus further includes a query processing unit configured to process the multiple continuous aggregate queries based on the first operation result and the second operation result.

主权项

1. An apparatus configured to process multiple continuous aggregate queries in data streams, the apparatus comprising:
a first operation result sharing unit configured to generate a common window comprising first aggregate areas, store a first operation result of each of the multiple continuous aggregate queries for each of the first aggregate areas, and calculate an inclusion count (IC) of each of the first aggregate areas; a second operation result sharing unit configured to determine a second aggregate area comprising at least one of the first aggregate areas, and store a second operation result of each of the multiple continuous aggregate queries for the second aggregate area; and a query processing unit configured to process the multiple continuous aggregate queries based on the first operation result and the second operation result; wherein the IC is a number of the sliding windows corresponding to a respective first aggregate area of the common window, wherein the common window comprises edges of each sliding window for the multiple continuous aggregate queries and each of the first aggregate areas is partitioned by two adjacent edges of the edges, and wherein the multiple continuous aggregate queries comprise different sliding windows, and a same type of an aggregate operation.