发明名称 |
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 groups. 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. |
申请公布号 |
US8762369(B2) |
申请公布日期 |
2014.06.24 |
申请号 |
US201114113555 |
申请日期 |
2011.05.10 |
申请人 |
Telefonaktiebolaget L M Ericsson (publ) |
发明人 |
Macho David Manzano;Pallares Lopez Miguel Angel |
分类号 |
G06F17/30 |
主分类号 |
G06F17/30 |
代理机构 |
Christopher & Weisberg, P.A. |
代理人 |
Christopher & Weisberg, P.A. |
主权项 |
1. A continuous query result estimator for use in a data stream management system to reduce data stream processing times, the data stream management system being 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 comprising:
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 groups; a data store configured to store, in association with each of the input data groups, a respective rule for estimating a result of executing the continuous query against a data item belonging to the input data group; and 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; andapply the selected rule to the received set of data items to generate an estimate for a result of executing the continuous query against the received set of data items.
|
地址 |
Stockholm SE |