Real-time mining and reduction of streamed data
First Claim
Patent Images
1. An apparatus comprising:
- at least one processor;
a memory coupled to the at least one processor; and
a stream data node residing in the memory that receives streamed data from at least one data source, dynamically reduces the streamed data using a filter mechanism that specifies data to exclude from the streamed data according to at least one filter criterion as the streamed data is received before storing the streamed data in a database, and delivers the reduced streamed data when an external request is received, wherein the stream data node is part of a query execution data structure representing a query execution plan for querying data stored in database tables, wherein the query execution data structure includes at least one join node, and wherein the stream data node delivers the reduced streamed data when requested by a different node in the query execution data structure.
0 Assignments
0 Petitions
Accused Products
Abstract
A stream data node receives real-time streamed data from one or more input devices, dynamically filters the streamed data to reduce the streamed data, and delivers the reduced data when requested. By providing real-time filtering of the data, the amount of data that must be stored in a database may be substantially reduced. The stream data node can perform aggregation functions, group functions, and select functions, thereby also significantly reducing the amount of data that must be stored in a database. The stream data node may also be part of a query execution data structure, where it delivers its data when requested by another node in the query execution data structure.
28 Citations
14 Claims
-
1. An apparatus comprising:
-
at least one processor; a memory coupled to the at least one processor; and a stream data node residing in the memory that receives streamed data from at least one data source, dynamically reduces the streamed data using a filter mechanism that specifies data to exclude from the streamed data according to at least one filter criterion as the streamed data is received before storing the streamed data in a database, and delivers the reduced streamed data when an external request is received, wherein the stream data node is part of a query execution data structure representing a query execution plan for querying data stored in database tables, wherein the query execution data structure includes at least one join node, and wherein the stream data node delivers the reduced streamed data when requested by a different node in the query execution data structure. - View Dependent Claims (2, 3, 4)
-
-
5. A computer-implemented method for processing streamed data from at least one data source, the method comprising the steps of:
-
(A) providing at least one processor; (B) providing a computer readable memory coupled to the at least one processor; (C) a stream data node receiving the streamed data from the at least one data source, wherein the stream data node is part of a query execution data structure representing a query execution plan for querying data stored in database tables, wherein the query execution data structure includes at least one join node; (D) the stream data node dynamically reducing the streamed data using a filter mechanism that specifies data to exclude from the streamed data according to at least one filter criterion as the streamed data is received before storing the streamed data in a database in the memory; and (E) the stream data node delivering the reduced streamed data from the database in the memory when requested by a different node in the query execution data structure. - View Dependent Claims (6, 7, 8, 9, 10)
-
-
11. A computer-readable program product comprising software residing on non-transitory media, the software comprising:
a stream data node that receives streamed data from at least one data source, dynamically reduces the streamed data using a filter mechanism that specifies data to exclude from the streamed data according to at least one filter criterion as the streamed data is received before storing the streamed data in a database, and delivers the reduced streamed data when an external request is received, wherein the stream data node is part of a query execution data structure representing a query execution plan for querying data stored in database tables, wherein the query execution data structure includes at least one join node, and wherein the stream data node delivers the reduced streamed data when requested by a different node in the query execution data structure. - View Dependent Claims (12, 13, 14)
Specification