System and method for processing continuous queries with aggregating functions using accumulators
AssigneeMicrosoft Technology Licensing, LLC
InventorDaniel Donald Gerlag
Life of this patent
Estimating the term…
Abstract
A method, computer program product, and computing system for processing a continuous query including an aggregating function. An accumulator associated with the aggregating function is identified. A current aggregation result is generated for the aggregating function of the continuous query without accessing every entry of the accumulator. A continuous query result is generated for the continuous query using the accumulator associated with the aggregating function.
Claims20
A method, comprising:
- processing a continuous query directed to a database, the continuous query comprising an aggregating function to be applied over a set of elements of the database;
- identifying an accumulator, associated with the aggregating function, that stores one or more values from the set of elements of the database identified by the aggregating function;
- determining an aggregation result for the aggregating function based on a subset of the one or more values from the set of elements of the database stored in the accumulator;
- storing, in the accumulator, the aggregation result of the aggregating function of the continuous query;
- and
- generating a continuous query result for the continuous query based on the aggregation result stored in the accumulator associated with the aggregating function.
A computing system comprising:
- a memory;
- and
- a processor operatively coupled to the memory, the processor configured to;
- process a continuous query directed to a database, the continuous query comprising an aggregating function to be applied over a set of elements of the database,
- identify an accumulator, associated with the aggregating function, that stores one or more values from the set of elements of the database identified by the aggregating function,
- determine an aggregation result for the aggregating function based on a subset of the one or more values from the set of elements of the database stored in the accumulator,
- store, in the accumulator, the aggregation result of the aggregating function of the continuous query,
- generate a continuous query result for the continuous query based on the aggregation result stored in the accumulator associated with the aggregating function, and
- persist the accumulator to a storage device.
A non-transitory computer readable storage medium having instructions stored thereon which, when executed by a processor, cause the processor to:
- process a continuous query directed to a database, the continuous query comprising an aggregating function to be applied over a set of elements of the database;
- identify an accumulator, associated with the aggregating function, that stores one or more values from the set of elements of the database identified by the aggregating function;
- determine an aggregation result for the aggregating function based on a subset of the one or more values from the set of elements of the database stored in the accumulator,
- store, in the accumulator, the aggregation result of the aggregating function of the continuous query;
- and
- generate a continuous query result for the continuous query based on the aggregation result stored in the accumulator associated with the aggregating function.
Dependencies are inferred from the claim text.