Generating And Using Temporal Data Partition Revisions

• US 20140164409A1
• Filed: 12/06/2012
• Published: 06/12/2014
• Est. Priority Date: 12/06/2012
• Status: Active Grant

• Current Assignee: AT&T Intellectual Property I LP (AT&T, Inc.)
• Original Assignee: AT&T Intellectual Property I LP (AT&T, Inc.)
• Inventors: Johnson, Theodore, Hadjieleftheriou, Marios, Shkapenyuk, Vladislav
• Granted Patent: US 9,600,526 B2
• Time in Patent Office: Days
• US Class Current: 707/756
• CPC Class Codes: G06F 16/2379 Updates performed during online database operations; commit processing
• CPC Class Codes: G06F 16/24561 Intermediate data storage techniques for performance improvement

Abstract

Concepts and technologies are disclosed herein for generating and using temporal data partition revisions. In some embodiments, a server computer can execute a data management application. The server computer can obtain a data partition associated with a data stream. The data partition can include a data point and a timestamp. The server computer can analyze the timestamp to determine if the data partition corresponds to an update of a base data record. If the server computer determines that the data corresponds to an update, the server computer can compute a revision comprising a delta and a timestamp and store the revision.

Claims

1. A method comprising:

obtaining, at a server computer executing a data management application, a data partition associated with a data stream, the data partition comprising a data point and a timestamp;

analyzing, by the server computer, the timestamp to determine if the data partition corresponds to an update of a base data partition;

in response to a determination that the data partition corresponds to the update, computing, by the server computer, a revision comprising a delta and the timestamp; and

storing, by the server computer, the revision.

2. The method of claim 1, wherein computing the revision comprises generating an identifier and including the identifier in the revision.

3. The method of claim 2, wherein the base data partition stores a base data identifier, and wherein the identifier and the base data identifier are the same.

4. The method of claim 1, wherein the data partition comprises an identifier, wherein the base data partition stores a base data identifier, and wherein determining that the data partition corresponds to the update comprises determining that the identifier is the same as the base data identifier.

5. The method of claim 1, further comprising:

receiving a query;

executing the query against the base data partition; and

storing a result set comprising results of the query against the base data partition.

6. The method of claim 5, wherein the result set comprises the base data partition.

7. The method of claim 6, further comprising:

determining if a base data revision is stored;

in response to a determination that the base data revision is stored, retrieving the base data revision;

applying the base data revision to the base data partition to generate an updated version of the base data partition; and

outputting a result comprising the updated base data partition.

8. The method of claim 1, further comprising:

retrieving two revisions comprising updates to the base data partition;

merging the two revisions to generate a merged revision;

applying the merged revision to the base data partition to generate an updated base data partition; and

saving the updated base data partition as base data.

9. The method of claim 8, wherein retrieving two revisions comprises identifying base data comprising an identifier, and wherein each of the two revisions comprises a revision identifier that is the same as the identifier.

10. The method of claim 8, wherein each of the two revisions comprises a respective delta and a respective timestamp, wherein generating the updated base data partition comprises merging each respective delta to generate a merged delta, determining a most recent timestamp, and generating the merged revision, wherein the merged revision comprises the merged delta and the most recent timestamp.

11. A system comprising:

a processor; and

a memory that stores computer-executable instructions that, when executed by the processor, cause the processor to perform operations comprising;

obtaining a data partition associated with a data stream, the data partition comprising a timestamp;

analyzing the timestamp to determine if the data partition corresponds to an update of a base data partition;

in response to a determination that the data partition corresponds to the update, computing a revision comprising a delta and the timestamp; and

storing the revision.

12. The system of claim 11, further comprising a data store that stores the base data partition and revision data, wherein the revision is stored as the revision data.

13. The system of claim 11, wherein the computer-executable instructions, when executed by the processor, cause the processor to perform operations further comprising:

receiving a query;

executing the query against the base data comprising the base data partition; and

storing a result set comprising results of the query against the base data, the result set comprising the base data partition.

14. The system of claim 13, wherein the computer-executable instructions, when executed by the processor, cause the processor to perform operations further comprising:

determining if a base data revision is stored;

in response to a determination that the base data revision is stored, retrieving the base data revision;

applying the base data revision to the base data partition to generate an updated base data partition; and

outputting a result comprising the updated base data partition.

15. The system of claim 11, wherein the computer-executable instructions, when executed by the processor, cause the processor to perform operations further comprising:

retrieving two revisions comprising updates to the base data partition;

merging the two revisions to generate a merged revision;

applying the merged revision to the base data partition to generate an updated base data partition; and

saving the updated base data partition as base data.

16. A computer storage medium having computer-executable instructions stored thereon that, when executed by a processor, cause the processor to perform operations comprising:

obtaining a data partition associated with a data stream, the data partition comprising a data point and a timestamp;

analyzing the timestamp to determine if the data partition corresponds to an update of a base data partition;

in response to a determination that the data partition corresponds to the update, computing a revision comprising a delta and the timestamp; and

storing the revision.

17. The computer storage medium of claim 16, further comprising computer-executable instructions that, when executed by the processor, cause the process to perform operations further comprising:

retrieving two revisions comprising updates to the base data partition;

merging the two revisions to generate a merged revision;

applying the merged revision to the base data partition to generate an updated base data partition; and

saving the updated base data partition as base data.

18. The computer storage medium of claim 16, further comprising computer-executable instructions that, when executed by the processor, cause the process to perform operations further comprising:

receiving a query;

executing the query against base data comprising the base data partition; and

storing a result set comprising results of the query against the base data, the result set comprising the base data partition.

19. The computer storage medium of claim 18, further comprising computer-executable instructions that, when executed by the processor, cause the process to perform operations further comprising:

determining if a base data revision is stored;

in response to a determination that the base data revision is stored, retrieving the base data revision;

applying the base data revision to the base data partition to generate an updated base data partition; and

outputting a result comprising the updated base data partition.

20. The computer storage medium of claim 16, wherein the data partition is obtained from a data stream generated by a data source, and wherein obtaining the data partition comprises receiving the data partition in a temporal release of the data partition by the data source.