Determining and extracting changed data from a data source

• US 8,935,201 B1
• Filed: 04/16/2014
• Issued: 01/13/2015
• Est. Priority Date: 03/18/2014
• Status: Active Grant

• Current Assignee: Palantir Technologies Incorporated
• Original Assignee: Palantir Technologies Incorporated
• Inventors: Fisher, William, Maag, Peter
• Primary Examiner(s): Uddin, Md. I
• Application Number:
  US14/254,757
• Time in Patent Office: 272 Days
• Field of Search: 707/610, 707/609, 707/625, 707/638, 707/648, 707/754, 707/758
• US Class Current: 707/609
• CPC Class Codes: G06F 11/1453 using de-duplication of the data
• CPC Class Codes: G06F 16/00 Information retrieval; Database structures therefor; File system structures therefor
• CPC Class Codes: G06F 16/1748 De-duplication implemented within the file system, e.g. based on file segments de-duplication techniques in storage systems for the management of data blocks G06F3/0641
• CPC Class Codes: G06F 16/178 Techniques for file synchronisation in file systems
• CPC Class Codes: G06F 16/23 Updating
• CPC Class Codes: G06F 16/2308 Concurrency control transaction processing G06F9/466
• CPC Class Codes: G06F 16/2322 using timestamps
• CPC Class Codes: G06F 16/2365 Ensuring data consistency and integrity
• CPC Class Codes: G06F 16/2379 Updates performed during online database operations; commit processing
• CPC Class Codes: G06F 16/24 Querying
• CPC Class Codes: G06F 16/245 Query processing
• CPC Class Codes: G06F 16/2477 Temporal data queries
• CPC Class Codes: G06F 16/273 Asynchronous replication or reconciliation
• CPC Class Codes: G06F 16/285 Clustering or classification
• CPC Class Codes: G06F 7/24 Sorting, i.e. extracting data from one or more carriers, rearranging the data in numerical or other ordered sequence, and rerecording the sorted data on the original carrier or on a different carrier or set of carriers sorting methods in generalG06F7/36 takes precedence

Abstract

According to certain aspects, a computer system may be configured to obtain information indicating a plurality of groupings of data stored in a data source, the information indicating a number of data items included in each of the plurality of groupings; determine a first grouping of the plurality of groupings including one or more data items that have changed by comparing a first number of data items included in the first grouping and a historical first number of data items included in a corresponding local version of the first grouping; access data items included in the first grouping from the data source; compare the data items included in the first grouping to data items of the corresponding local version of the first grouping to determine which data items have changed; extract the changed data items of the first grouping; and forward the extracted data items to a destination system.

Claims

1. A computer system configured to obtain changed data from a data source, the computer system comprising:

one or more hardware computer processors configured to execute code in order to cause the system to;

obtain information indicating a plurality of groupings of data stored in one or more files or databases in a data source, wherein the plurality of groupings is based on date and time of timestamps of respective data items such that an uneven distribution of data items included in the plurality of groupings is provided, each of the groupings associated with a different data item attribute such that respective groupings each include data items having the corresponding data item attribute, wherein the information indicates a current quantity of data items included in each of the plurality of groupings at a current time, wherein the information is obtained using a query of a timestamp data item attribute;

access historical grouping information indicating a historical quantity of data items included in at least some of the plurality of groupings at a previous time, wherein for a first subset of the groupings a current quantity of data items at the current time and a historical quantity of data items are not equal, and for another subset of the groupings a current quantity of data items and a historical quantity of data items are equal;

compare the quantity of data items in the same groupings at the previous time and the current time;

determine, based on said comparing, that a first current quantity of data items included in a first grouping and a first historical quantity of data items included in a first historical grouping of data items are not equal, indicating that one or more data items of the first grouping have changed; and

in response to determining that the first current quantity of data items is higher or lower than the first historical quantity of data items;

access data items included in the first grouping from the data source;

compare the data items included in the first grouping to data items of a corresponding local version of the first grouping to determine which data items of the first grouping from the data source have changed;

extract the changed data items of the first grouping; and

forward the extracted changed data items to a destination system.

2. The system of claim 1, wherein the plurality of groupings is based on the timestamps of the respective data items, wherein the timestamps indicate respective times at which data items were last updated.

3. The system of claim 2, wherein the timestamps of the respective data items include a date and a time at which the respective data items were last updated, and wherein the plurality of groupings is based on only the date of the timestamps of the respective data items.

4. The system of claim 3, wherein each of the plurality of groupings is associated with a different date.

5. The system of claim 3, wherein the dates associated with each of the plurality of groupings are within a range of dates.

6. The system of claim 1, wherein the corresponding local version of the first grouping comprises a copy of the data items included in the first grouping at a first time prior to said obtaining the information indicating the plurality of groupings of the data.

7. The system of claim 1, wherein, in response to determining that the first current quantity of data items is higher than the first historical quantity of data items, the code is further configured to cause the system to:

identify the changed data items as added or updated data items; and

forward the changed data items to the destination system to be stored.

8. The system of claim 1, wherein, in response to determining that the first current quantity of data items is lower than the first historical quantity of data items, the code is further configured to cause the system to:

identify the changed data items as deleted data items; and

forward the changed data items to the destination system to be removed.

9. The system of claim 1, wherein the code is further configured to:

assign a unique identifier to each of the data items included in the first grouping; and

determine whether a first changed data item of the changed data items is a new data item or an updated data item based on the unique identifier associated with the first changed data item.

10. The system of claim 1, wherein a data item included in the first grouping is a row in the one or more databases or a line in the one or more files.

11. The system of claim 1, wherein the code is further configured to cause the system to:

obtain the information indicating the plurality of groupings of the data stored in the one or more files in the data source using a first adapter; and

obtain the information indicating the plurality of groupings of the data stored in the one or more databases in the data source using a second adapter.

12. The system of claim 1, wherein the code is further configured to cause the system to obtain the information indicating the plurality of groupings of the data at an interval.

13. The system of claim 1, wherein the code is further configured to cause the system to obtain the information indicating the plurality of groupings of the data in response to receiving a request from the destination system.

14. A method of obtaining changed data from a data source, the method comprising:

obtaining, by one or more hardware computer processors, information indicating a plurality of groupings of data stored in one or more files or databases in a data source, wherein the plurality of groupings is based on date and time of timestamps of respective data items such that an uneven distribution of data items included in the plurality of groupings is provided, each of the groupings associated with a different data item attribute such that respective groupings each include data items having the corresponding data item attribute, wherein the information indicates a current quantity of data items included in each of the plurality of groupings at a current time, wherein the information is obtained using a query of a timestamp data item attribute;

accessing, by the one or more hardware computer processors, historical grouping information indicating a historical quantity of data items included in at least some of the plurality of groupings at a previous time, wherein for a first subset of the groupings a current quantity of data items at the current time and a historical quantity of data items are not equal, and for another subset of the groupings a current quantity of data items and a historical quantity of data items are equal;

comparing, by the one or more hardware computer processors, the quantity of data items in the same groupings at the previous time and the current time;

determining, by the one or more hardware computer processors, based on said comparing, that a first current quantity of data items included in a first grouping and a first historical quantity of data items included in a first historical grouping of data items are not equal, indicating that one or more data items of the first grouping have changed; and

in response to determining that the first current quantity of data items is higher or lower than the first historical quantity of data items;

accessing, by the one or more hardware computer processors, data items included in the first grouping from the data source;

comparing, by the one or more hardware computer processors, the data items included in the first grouping to data items of a corresponding local version of the first grouping to determine which data items of the first grouping from the data source have changed;

extracting, by the one or more hardware computer processors, the changed data items of the first grouping; and

forwarding, by the one or more hardware computer processors, the extracted changed data items to a destination system.

15. The method of claim 14, wherein the plurality of groupings is based on the timestamps of the respective data items, wherein the timestamps indicate respective times at which data items were last updated.

16. The method of claim 14, wherein the corresponding local version of the first grouping comprises a copy of data items included in the first grouping at a first time prior to said obtaining the information indicating the plurality of groupings of the data.

17. The method of claim 14, wherein a data item included in the first grouping is a row in the one or more databases or a line in the one or more files.

18. A non-transitory computer readable storage medium comprising instructions for obtaining changed data from a data source that cause a computer processor to:

obtain information indicating a plurality of groupings of data stored in one or more files or databases in a data source, wherein the plurality of groupings is based on date and time of timestamps of respective data items such that an uneven distribution of data items included in the plurality of groupings is provided, each of the groupings associated with a different data item attribute such that respective groupings each include data items having the corresponding data item attribute, wherein the information indicates a current quantity of data items included in each of the plurality of groupings at a current time, wherein the information is obtained using a query of a timestamp data item attribute;

access historical grouping information indicating a historical quantity of data items included in at least some of the plurality of groupings at a previous time, wherein for a first subset of the groupings a current quantity of data items at the current time and a historical quantity of data items are not equal, and for another subset of the groupings a current quantity of data items and a historical quantity of data items are equal;

compare the quantity of data items in the same groupings at the previous time and the current time;

determine, based on said comparing, that a first current quantity of data items included in a first grouping and a first historical quantity of data items included in a first historical grouping of data items are not equal, indicating that one or more data items of the first grouping have changed; and

in response to determining that the first current quantity of data items is higher or lower than the first historical quantity of data items;

access data items included in the first grouping from the data source;

compare the data items included in the first grouping to data items of a corresponding local version of the first grouping to determine which data items of the first grouping from the data source have changed;

extract the changed data items of the first grouping; and

forward the extracted changed data items to a destination system.

19. The computer readable storage medium of claim 18, wherein the plurality of groupings is based on the timestamps of the respective data items, wherein the timestamps indicate respective times at which data items were last updated.

20. The computer readable storage medium of claim 18, wherein the corresponding local version of the first grouping comprises a copy of data items included in the first grouping at a first time prior to said obtaining the information indicating the plurality of groupings of the data.