Method and Apparatus for Efficient Aggregate Computation over Data Streams
First Claim
1. A method, comprising:
- obtaining a data stream;
obtaining a set of aggregate queries to be executed on the data stream; and
generating a query plan for executing the set of aggregate queries on the data stream, wherein the generated query plan comprises generating at least one intermediate aggregate query, wherein the intermediate aggregate query combines a subset of aggregate queries from the set of aggregate queries so as to pre-aggregate data from the data stream prior to execution of the subset of aggregate queries such that the generated query plan is optimized for computational expense based on a given cost model.
5 Assignments
0 Petitions
Accused Products
Abstract
Improved techniques are disclosed for processing data stream queries wherein a data stream is obtained, a set of aggregate queries to be executed on the data stream is obtained, and a query plan for executing the set of aggregate queries on the data stream is generated. In a first method, the generated query plan includes generating at least one intermediate aggregate query, wherein the intermediate aggregate query combines a subset of aggregate queries from the set of aggregate queries so as to pre-aggregate data from the data stream prior to execution of the subset of aggregate queries such that the generated query plan is optimized for computational expense based on a given cost model. In a second method, the generated query plan includes identifying similar filters in two or more aggregate queries of the set of aggregate queries and combining the similar filters into a single filter such that the single filter is usable to pre-filter data input to the two or more aggregate queries.
-
Citations
20 Claims
-
1. A method, comprising:
-
obtaining a data stream; obtaining a set of aggregate queries to be executed on the data stream; and generating a query plan for executing the set of aggregate queries on the data stream, wherein the generated query plan comprises generating at least one intermediate aggregate query, wherein the intermediate aggregate query combines a subset of aggregate queries from the set of aggregate queries so as to pre-aggregate data from the data stream prior to execution of the subset of aggregate queries such that the generated query plan is optimized for computational expense based on a given cost model. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10)
-
-
11. A method, comprising:
-
obtaining a data stream; obtaining a set of aggregate queries to be executed on the data stream; and generating a query plan for executing the set of aggregate queries on the data stream, wherein the generated query plan comprises identifying similar filters in two or more aggregate queries of the set of aggregate queries and combining the similar filters into a single filter such that the single filter is usable to pre-filter data input to the two or more aggregate queries. - View Dependent Claims (12, 13)
-
-
14. Apparatus, comprising:
-
a memory; and a processor coupled to the memory and operative to;
obtain a data stream;
obtain a set of aggregate queries to be executed on the data stream; and
generate a query plan for executing the set of aggregate queries on the data stream, wherein the generated query plan comprises at least one of;
(i) generating at least one intermediate aggregate query, wherein the intermediate aggregate query combines a subset of aggregate queries from the set of aggregate queries so as to pre-aggregate data from the data stream prior to execution of the subset of aggregate queries such that the generated query plan is optimized for computational expense based on a given cost model; and
(ii) identifying similar filters in two or more aggregate queries of the set of aggregate queries and combining the similar filters into a single filter such that the single filter is usable to pre-filter data input to the two or more aggregate queries. - View Dependent Claims (15, 16, 17, 18, 19, 20)
-
Specification