MULTI-STREAMS ANALYTICS

• US 20130080413A1
• Filed: 09/28/2011
• Published: 03/28/2013
• Est. Priority Date: 09/28/2011
• Status: Active Grant

• Current Assignee: Micro Focus LLC (Open Text Corporation)
• Original Assignee: HP Inc.
• Inventors: Chen, Qiming, Hsu, Meichun
• Granted Patent: US 8,880,493 B2
• Time in Patent Office: Days
• US Class Current: 707/706
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/278 Data partitioning, e.g. horizontal or vertical partitioning

Abstract

Multi-stream analytics is disclosed. An example method of multi-stream analytics with a query engine includes punctuating unbounded streaming data into data chunks, each of the data chunks representing a bounded data set in the unbounded streaming data. The method also includes processing one of the data chunks. The method also includes rewinding a query instance for processing another of the data chunks.

Claims

1. A method of multi-stream analytics with a query engine, comprising:

punctuating unbounded streaming data into data chunks, each of the data chunks representing a bounded data set in the unbounded streaming data;

processing one of the data chunks; and

rewinding a query instance for processing another of the data chunks.

2. The method of claim 1, further comprising executing a sequence of query cycles on a sequence of the data chunks.

3. The method of claim 1, further comprising joining multiple streams and self-joining a single stream using a data chunk-based window or sliding window.

4. The method of claim 1, further comprising joining multiple input streams.

5. The method of claim 1, further comprising joining a stream window and a static table.

6. The method of claim 1, further comprising window-joining multiple input streams.

7. The method of claim 1, further comprising joining streams in sliding windows.

8. The method of claim 1, further comprising self-joining a stream in a sliding window.

9. The method of claim 1, wherein the query uses structured query language (SQL).

10. A system having a query engine executing program code for multi-stream analytics, the program code stored on a non-transient computer readable medium and executed to:

punctuate unbounded streaming data into data chunks representing bounded data sets;

execute a query instance on one of the data chunks, and then rewind the query instance; and

execute a sequence of query cycles on a sequence of the data chunks.

11. The system of claim 10, wherein the program code is further executed to join multiple streams and self-join a single stream using a data chunk-based window or sliding window.

12. The system of claim 10, wherein the program code is further executed to join multiple input streams.

13. The system of claim 10, wherein the program code is further executed to join a stream window and a static table.

14. The system of claim 10, wherein the program code is further executed to join streams in sliding windows.

15. The system of claim 10, wherein the program code is further executed to self-join a stream in a sliding window.