PROGRESSIVE QUERY COMPUTATION USING STREAMING ARCHITECTURES
First Claim
1. A method comprising:
- obtaining a relational query that references one or more data items;
associating progress intervals with the data items;
converting the relational query into a corresponding streaming query; and
providing the streaming query and the data items with the progress intervals to a stream engine that produces incremental results of the query,wherein at least the associating is performed by a computing device.
3 Assignments
0 Petitions
Accused Products
Abstract
The described implementations relate to processing of electronic data. One implementation is manifest as a technique that can include obtaining a relational query that references one or more data items and associating progress intervals with the data items. The technique can also include converting the relational query into a corresponding streaming query, and providing the streaming query and the data items with the progress intervals to a stream engine that produces incremental results of the query. For example, the progress intervals can be based on row numbers of a relational database table. The progress intervals can be used to define event lifetimes of streaming events that are provided as inputs to the stream engine.
-
Citations
20 Claims
-
1. A method comprising:
-
obtaining a relational query that references one or more data items; associating progress intervals with the data items; converting the relational query into a corresponding streaming query; and providing the streaming query and the data items with the progress intervals to a stream engine that produces incremental results of the query, wherein at least the associating is performed by a computing device. - View Dependent Claims (2, 3, 4, 5, 6, 7)
-
-
8. One or more computer-readable storage media comprising instructions which, when executed by one or more processors, cause the one or more processors to perform acts comprising:
-
processing a relational query using a stream engine configured to process streaming queries; and updating an interface with incremental results produced by the stream engine. - View Dependent Claims (9, 10, 11, 12, 13)
-
-
14. A system comprising:
-
logic configured to; receive a first code entry, receive a second code entry that relies on results of the first code entry, and provide a visualization of progressive results of the first code entry and the second code entry; and at least one processing device configured to execute the logic. - View Dependent Claims (15, 16, 17, 18, 19, 20)
-
Specification