Apparatus and method for facilitating continuous querying of multi-dimensional data streams
First Claim
Patent Images
1. A non-transitory computer readable storage medium, comprising executable instructions to:
- provide a plurality of query frames for generating continuous queries of multi-dimensional data stream, each query frame having associated metadata characterizing the query frame, and each query frame comprising a plurality of meta-sections with descriptive textual information about the query frame, the plurality of meta-sections including a meta-section that characterizes a past predetermined amount of time for which a continuous query associated with the query frame is evaluated;
provide a query interface for formulating continuous queries of the multi-dimensional data streams, the multi-dimensional data streams comprising sequences of time-stamped data items or tuples across two or more dimensions that have a fixed schema or structure and arrive in a given time order, the continuous queries evaluating continuously as new data arrive on the multi-dimensional data streams;
receive, via the query interface, user-generated input specifying search criteria;
search for query frames having metadata matching the search criteria;
populate, using at least one query frame having metadata matching criteria, the query interface to generate a plurality of continuous queries;
execute the plurality of continuous queries against the multi-dimensional data streams; and
modify the plurality of continuous queries at run-time.
2 Assignments
0 Petitions
Accused Products
Abstract
A computer readable storage medium comprises executable instructions to provide a query interface for formulating continuous queries of multi-dimensional data streams. The query interface is populated to generate a plurality of continuous queries. The plurality of continuous queries are executed. The plurality of continuous queries are modified at run-time.
64 Citations
23 Claims
-
1. A non-transitory computer readable storage medium, comprising executable instructions to:
-
provide a plurality of query frames for generating continuous queries of multi-dimensional data stream, each query frame having associated metadata characterizing the query frame, and each query frame comprising a plurality of meta-sections with descriptive textual information about the query frame, the plurality of meta-sections including a meta-section that characterizes a past predetermined amount of time for which a continuous query associated with the query frame is evaluated; provide a query interface for formulating continuous queries of the multi-dimensional data streams, the multi-dimensional data streams comprising sequences of time-stamped data items or tuples across two or more dimensions that have a fixed schema or structure and arrive in a given time order, the continuous queries evaluating continuously as new data arrive on the multi-dimensional data streams; receive, via the query interface, user-generated input specifying search criteria; search for query frames having metadata matching the search criteria; populate, using at least one query frame having metadata matching criteria, the query interface to generate a plurality of continuous queries; execute the plurality of continuous queries against the multi-dimensional data streams; and modify the plurality of continuous queries at run-time. - View Dependent Claims (2, 3, 4, 5, 6, 7, 8, 9, 10, 11, 12, 13, 14, 15)
-
-
16. A non-transitory computer readable storage medium, comprising executable instructions to:
-
provide a plurality of query frames for generating continuous queries of multi-dimensional data streams, the multi-dimensional data streams comprising sequences of time-stamped data items or tuples across two or more dimensions that have a fixed schema or structure and arrive in a given time order the continuous queries evaluating continuously as new data arrive on the multi-dimensional data streams, each query frame comprising a plurality of meta-sections with descriptive textual information about the query frame, the plurality of meta-sections including a meta-section that characterizes a past predetermined amount of time for which a continuous query associated with the query frame is evaluated; store the plurality of query frames in a query catalog along with natural language descriptions characterizing the respective query frames; receive user-generated input via a graphical user interface specifying search criteria; search for query frames in the query catalog having natural language descriptions matching the search criteria; populate the query frames matching the search criteria to generate populated query frames; and convert the populated query frames into continuous queries against the multi-dimensional data streams. - View Dependent Claims (17, 18, 19, 20)
-
-
21. A method for facilitating the formulation of continuous queries, the method comprising:
-
providing a plurality of query frames for formulating continuous queries of multi-dimensional data streams, the multi-dimensional data streams comprising sequences of time-stamped data items or tuples across two or more dimensions that have a fixed schema or structure and arrive in a given time order the continuous queries evaluating continuously as new data arrive on the multi-dimensional data streams, each query frame comprising a plurality of meta-sections with descriptive textual information about the query frame, the plurality of meta-sections including a meta-section that characterizes a past predetermined amount of time for which a continuous query associated with the query frame is evaluated; providing a graphical user interface for populating one or more of the plurality of query frames to generate populated query frames; storing the populated query frames and metadata characterizing each of the populated query frames in a query catalog; searching for query frames in the query catalog having corresponding metadata matching a search criteria, each continuous query of the continuous queries being configured to be formulated by a user without programming knowledge; converting, based on the searching, the populated query frames into continuous queries; and executing the continuous queries against the multi-dimensional data streams. - View Dependent Claims (22, 23)
-
Specification