System and method for managing data streams
First Claim
Patent Images
1. A datastream management system comprising:
- a. a filter transform aggregate for managing a high speed input data stream with a plurality of packets, wherein each packet comprises at least one attribute, and wherein the filter transform aggregate comprises;
i. an evaluation system to evaluate the high speed input data stream and to partition the plurality of packets into groups using similar attributes;
ii. a table to store the attributes of the plurality of packets using a hash function; and
iii. computer instruction to form a phantom query, wherein the phantom query uses a partitioned group of packets with attributes different than those used to group the plurality of packets into groups for solving user queries without performing the user queries on the high speed input data stream;
b. a memory storing the filter transform aggregate; and
c. a processor operating the filter transform aggregate.
2 Assignments
0 Petitions
Accused Products
Abstract
A system for a data stream management system includes a filter transport aggregate for a high speed input data stream with a plurality of packets each packet comprising attributes. The system includes an evaluation system to evaluate the high speed input data stream and partitions the packets into groups the attributes and a table, wherein the table stores the attributes of each packets using a hash function. A phantom query is used to define partitioned groups of packets using attributes other than those used to group the packets for solving user queries without performing the user queries on the high speed input data stream.
-
Citations
20 Claims
-
1. A datastream management system comprising:
-
a. a filter transform aggregate for managing a high speed input data stream with a plurality of packets, wherein each packet comprises at least one attribute, and wherein the filter transform aggregate comprises; i. an evaluation system to evaluate the high speed input data stream and to partition the plurality of packets into groups using similar attributes; ii. a table to store the attributes of the plurality of packets using a hash function; and iii. computer instruction to form a phantom query, wherein the phantom query uses a partitioned group of packets with attributes different than those used to group the plurality of packets into groups for solving user queries without performing the user queries on the high speed input data stream; b. a memory storing the filter transform aggregate; and c. a processor operating the filter transform aggregate. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. A memory storing a set of instructions executable by a processor, the instructions operable to:
-
a. create a filter transform aggregate; b. administer a data stream with a plurality of packets, using the filter transform aggregate, wherein each packet comprises a plurality of attributes; c. perform an evaluation on the data stream and partition the plurality of packets into groups by based on similar attributes; d. apply a hash function to create a table in memory based on the attributes of the plurality of packets; and e. make a phantom query for a defined partitioned group of packets using attributes other than those used to group the packets, to simultaneously solve at least two user queries by applying a phantom query to the high speed data stream. - View Dependent Claims (9, 10, 11, 12, 13, 14, 15, 16)
-
-
17. A memory storing a set of instructions executable by a processor, the instructions operable to:
-
a. create a low level filter transform aggregate; b. create a high level filter transform aggregate; c. administer a high input data stream with a plurality of packets, wherein each packet comprises a plurality of attributes; d. perform an evaluation on the high input data stream, and partition the plurality of packets into groups by an attribute; e. create a table in memory based on the attributes of each packets using a hash function; and f. make a phantom query for a partitioned group of packets using attributes different than those used to group the plurality of packets to solve simultaneously at least two user queries by applying the phantom query to the high input data stream. - View Dependent Claims (18, 19, 20)
-
Specification