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.