Database and data stream query

• US 10,296,621 B2
• Filed: 09/30/2014
• Issued: 05/21/2019
• Est. Priority Date: 09/30/2014
• Status: Active Grant

• Current Assignee: Hewlett Packard Enterprise Development LP (Hewlett-Packard Enterprise Company)
• Original Assignee: Hewlett Packard Enterprise Development LP (Hewlett-Packard Enterprise Company)
• Inventors: Poppe, Olga, Simitsis, Alkiviadis, Wilkinson, William Kevin
• Primary Examiner(s): Bayou, Yonas A
• Application Number:
  US15/503,762
• Publication Number:
  US 20170270166A1
• Time in Patent Office: 1,694 Days
• CPC Class Codes: G06F 16/245 Query processing
• CPC Class Codes: G06F 16/2452 Query translation
• CPC Class Codes: G06F 16/24553 of query operations
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries
• CPC Class Codes: G06F 16/24578 using ranking
• CPC Class Codes: G06F 16/248 Presentation of query results

Abstract

Example implementations relate to a database and a data stream query. For example, a computing device may include a processor. The processor may receive a query associated with at least one of a database and a buffer storing streamed data from a data stream, where the database stores database data previously stored in the buffer. The processor may identify at least one postponed command relevant to the query, the at least one postponed command being associated with at least one of the database data and the streamed data. The processor may generate a modified query based on the query and the at least one postponed command, the modified query being a modification of the query to account for the at least one postponed command. The processor may process the modified query and provide a query result of the query based on the modified query being processed.

Claims

1. A computing device comprising:

a processor to;

receive a query associated with at least one of a database and a buffer storing streamed data from a data stream, the database storing database data previously stored in the buffer;

identify at least one postponed command received from the data stream and being relevant to the query, the at least one postponed command being delayed from execution and being associated with at least one of the database data and the streamed data;

generate a modified query based on the query and the at least one postponed command, the modified query being a modification of the query to account for the at least one postponed command;

process the modified query; and

provide a query result of the query based on the modified query being processed.

2. The computing device of claim 1, wherein the at least one postponed command is identified based on a range specified in the query.

3. The computing device of claim 2, wherein the range is at least one of a time range and a count range.

4. The computing device of claim 1, wherein the at least one postponed command includes at least one of an update command and a delete command.

5. The computing device of claim 1, wherein the modified query includes a database sub-query and a data stream sub-query, the database sub-query being processed based on the database and the at least one postponed command to generate a database sub-query result, the data stream sub-query being processed based on the data stream and the at least one postponed command to generate a data stream sub-query result, the query result being a combination of the database sub-query result and the data stream sub-query result.

6. The computing device of claim 1, wherein the at least one postponed command is postponed based on user-specified criteria.

7. A method comprising:

receiving, by a computing device, a query associated with at least one of a database and a buffer storing streamed data from a data stream, the database storing database data previously stored in the buffer;

determining, by the computing device, at least one postponed command relevant to the query, the at least one postponed command being associated with at least one of the database data and the streamed data;

creating, by the computing device, a modified query based on the query and the at least one postponed command, the modified query being a modification of the query to account for the at least one postponed command;

processing, by the computing device, the modified query; and

returning, by the computing device, a query result of the query based on the modified query being processed.

8. The method of claim 7, wherein the at least one postponed command includes at least one of an update command and a delete command.

9. The method of claim 7, wherein the modified query includes a database sub-query and a data stream sub-query, the database sub-query being processed based on the database and the at least one postponed command to generate a database sub-query result, the data stream sub-query being processed based on the data stream and the at least one postponed command to generate a data stream sub-query result, the query result being a combination of the database sub-query result and the data stream sub-query result.

10. The method of claim 7, wherein the at least one postponed command is postponed based on user-specified criteria.

11. A non-transitory machine-readable storage medium storing instructions that, if executed by at least one processor of a computing device, cause the computing device to:

receive a query associated with at least one of a database and a buffer storing streamed data from a data stream, the database storing database data previously stored in the buffer;

identify at least one postponed command relevant to the query, the at least one postponed command being associated with at least one of the database data and the streamed data;

generate a database sub-query and a data stream sub-query each based on the query and the at least one postponed command;

process the database sub-query and the data stream sub-query; and

provide a query result of the query, the query result being a combination of a database sub-query result of the database sub-query and a data stream sub-query result of the data stream sub-query.

12. The non-transitory machine-readable storage medium of claim 11, wherein the at least one postponed command is identified based on a range specified in the query.

13. The non-transitory machine-readable storage medium of claim 12, wherein the range is at least one of a time range and a count range.

14. The non-transitory machine-readable storage medium of claim 11, wherein the at least one postponed command includes at least one of an update command and a delete command.

15. The non-transitory machine-readable storage medium of claim 11, wherein the at least one postponed command is postponed based on user-specified criteria.