OPTIMIZED DATA STREAM MANAGEMENT SYSTEM

摘要

A continuous query result estimator for use in a data stream management system. The data stream management system configured to execute a continuous query against data items received via at least one input data stream to generate at least one output data stream. The continuous query result estimator comprises a classification module configured to classify a set of at least one data item received via the at least one input data stream into one of a plurality of input data group. A data store configured to store a respective rule for estimating a result of executing the continuous query against a data item belonging to the input data group. The continuous query result estimator also includes a result estimation module configured to select a rule from the rules stored in the data store on the basis of the classification performed by the classification module.