EFFICIENT EXECUTION OF AGGREGATION QUERIES

• US 20080133492A1
• Filed: 11/30/2006
• Published: 06/05/2008
• Est. Priority Date: 11/30/2006
• Status: Active Grant

• Current Assignee: Microsoft Technology Licensing LLC (Microsoft Corporation)
• Original Assignee: Microsoft Corporation
• Inventors: Vick, Paul A., Meijer, Henricus Johannes Maria, Silver, Amanda, Zabokritski, Evgueni, Tsingauz, Aleksey
• Granted Patent: US 7,769,755 B2
• Time in Patent Office: Days
• US Class Current: 707/4
• CPC Class Codes: G06F 16/24537 of operators
• CPC Class Codes: G06F 16/24556 Aggregation; Duplicate elimination

Abstract

A query language system is provided that includes a query component that specifies operations for one or more items in a data set. An aggregator component identifies one or more keys associated with the data set, the keys are supplied to one or more aggregators that perform direct computations from the keys in order to determine at least one aggregated value for the data set.

Claims

1. A query language system, comprising:

a query component that specifies operations for one or more items in a data set; and

an aggregator component that identifies one or more keys associated with the data set, the keys are supplied to one or more aggregators that perform direct computations from the keys to determine at least one aggregated value for the data set.

2. The system of claim 1, further comprising a class component to combine multiple aggregators into a single aggregator.

3. The system of claim 1, further comprising an overload component associated with a group by instruction.

4. The system of claim 3, the overload component is associated with at least one of an input element type, a type for a grouping key, an aggregate parameter type, an aggregate result type, and a group by result element type.

5. The system of claim 4, the overload component further comprising a key selector, a parameter selector, or result selector.

6. The system of claim 1, the aggregator component further comprising at least one of an initialization function, an aggregate method, and a terminate function.

7. The system of claim 6, the aggregator component further comprising a merge function the aggregates values from multiple aggregators.

8. The system of claim 1, further comprising an enumerator component to process aggregate results.

9. The system of claim 8, the enumerator component is associated with a hash table or dictionary to facilitate data aggregation.

10. The system of claim 1, further comprising a translation component to facilitate aggregate processing.

11. The system of claim 10, the translation component employs a composite argument or a composite result to process an aggregate value.

12. The system of claim 10, the translation component combines at least two different aggregators into a single aggregator.

13. A method for query processing and analysis, comprising:

iterating over a data set according to at least one query;

defining one or more keys to items located in the data set; and

creating one or more aggregators that are employed with the keys to facilitate direct execution of an aggregate value.

14. The method of claim 13, further comprising combining multiple aggregators into a single aggregator.

15. The method of claim 13, further comprising determining binding rules to be employed during language translations.

16. The method of claim 15, further comprising employing the binding rules to determine between aggregate functions and aggregator patterns.

17. The method of claim 13, further comprising processing one or more parameters in accordance with a group by operation.

18. The method of claim 17, further comprising defining one or more overload operators for the parameters.

19. The method of claim 13, further comprising generating at least one class to facilitate creation of the aggregators.

20. A system to process queries, comprising:

means for representing an item in a data set that is to be processed by a query execution engine; and

means for aggregating the item to facilitate direct computation of an aggregate data value.