| 主权项 |
1. A method comprising:
obtaining, at a server computer that executes a data management application, a data partition included in a data stream that is generated by a data source and streamed by the data source, the data partition comprising a single temporal release of a portion of a data table, wherein the portion of the data table is released multiple times over multiple temporal releases, and wherein the data partition comprises a record comprising a data point and a timestamp that indicates a time at which the data point was generated by the data source; analyzing, by the server computer, contents of the data partition, a header associated with the data partition, and base data stored at a data store to determine whether the data partition corresponds to a new partition or an update of a base data partition stored at the data store, the base data partition comprising a base data point and a base data timestamp associated with the base data; if a determination is made that the data partition corresponds to the new partition, storing, by the server computer, the new partition as part of the base data at the data store; if a determination is made that the data partition corresponds to the update, computing, by the server computer, a revision comprising
a revision identifier associated with the revision,a delta that defines a change made to the base data point by the revision, andthe timestamp that indicates the time at which the data point was generated by the data source; and storing, by the server computer, the revision as revision data that is stored separately from the base data partition. |
