Progressive query computation using streaming architectures

摘要

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.

主权项

1. A method comprising:
obtaining a relational query that references relational data items from a relational data table that lacks an explicit temporal attribute for ordering the relational data items of the relational data table; adapting the relational data items for processing by a stream engine by associating explicit temporal data with the relational data items, the explicit temporal data comprising different lifetimes; providing the relational data items and the explicit temporal data as input events to the stream engine, wherein the stream engine performs a streaming query, corresponding to the relational query, on the input events using the different lifetimes to identify individual relational data items that contribute to corresponding incremental results of the streaming query; obtaining the incremental results of the streaming query from the stream engine; and outputting the incremental results.