Data ingest optimization

• US 9,589,065 B2
• Filed: 09/05/2012
• Issued: 03/07/2017
• Est. Priority Date: 01/28/2011
• Status: Active Grant

• Current Assignee: International Business Machines Corporation
• Original Assignee: International Business Machines Corporation
• Inventors: Bhagwan, Varun, Grandison, Tyrone W. A., Gruhl, Daniel F.
• Primary Examiner(s): Choi, Yuk Ting
• Application Number:
  US13/604,096
• Publication Number:
  US 20120330972A1
• Time in Patent Office: 1,644 Days
• US Class Current: 1/1
• CPC Class Codes: G06F 16/951 Indexing; Web crawling techniques
• CPC Class Codes: G06F 16/957 Browsing optimisation, e.g. caching or content distillation

Abstract

Methods and systems for optimizing the retrieval of data from multiple sources are described. A slot map including slots for the storage of data elements can be obtained. The data elements associated with the slots can be prioritized by weighting values with costs of retrieving the data elements from respective data sources. Each value can be associated with a different data element and can indicate a respective degree of importance of the associated data element. Further, the systems and methods can direct the retrieval of data elements from the respective data sources in an order in accordance with the priority of the data elements to optimize the quality of data obtainable within a critical time constraint. In addition, the retrieved data elements can be stored in corresponding slots on a storage medium.

Claims

1. A computer readable storage medium comprising a non-transitory computer readable program code, wherein the computer readable program code when executed on a computer causes the computer to:

obtain a slot map including slots for the storage of data segments in a persistent storage device, the slot map including quality tag values associated with each of the data segments applied to each slot in the slot map;

prioritize the data segments associated with the slots by weighting the quality tag values, each of which is associated with a different slot and data segment and indicates a respective degree of importance of the associated data segment, with costs of retrieving the data segments from respective data sources and probabilities of successfully retrieving valid data segments from each of the respective data sources at one or more particular future times, and output a priority queue of the data segments;

populate the slot map with retrieved data segments and output the slot map; and

direct a retrieval of the data segments from the respective data sources in an order in accordance with a determined priority of the data segments to optimize a quality of data obtainable within a critical time constraint.

2. The computer readable storage medium of claim 1, wherein the data segments provide material for analysis of a subject and wherein each value indicates a respective degree of importance of a corresponding data segment in the analysis.

3. The computer readable storage medium of claim 1, wherein each value is based upon an expectation of success of retrieving the data segment associated with the value from a corresponding data source.

4. The computer readable storage medium of claim 1, wherein each value is based upon an expected resource expenditure of retrieving the data segment associated with the value from a corresponding data source.

5. The computer readable storage medium of claim 1, wherein the retrieval is constrained by at least one of a resource budget or a hard-stop end time.

6. The computer readable storage medium of claim 1, wherein the retrieval comprises adding additional slots to the slot map and repeating the prioritize step for the additional slots.

7. A system for optimizing the retrieval of data from multiple sources comprising:

a slot map generator configured to generate a slot map including slots for the storage of data segments in a persistent storage device, the slot map further including quality tag values associated with each of the data segments applied to each slot in the slot map;

a priority module configured to prioritize data segments associated with the slots by weighting the quality tag values, each of which is associated with a different slot and data segment and indicates a respective degree of importance of the associated data segment, with costs of retrieving the data segments from respective data sources and probabilities of successfully retrieving valid data segments from each of the respective data sources at one or more particular future times; and

a processor configured to direct a retrieval of the data segments from the respective data sources in an order in accordance with a determined priority of the data segments to optimize a quality of data obtainable within a critical resource constraint, the processor being further configured to output a priority queue of the data segments, populate the slot map with retrieved data segments, and output the slot map.

8. The system of claim 7, wherein the data segments provide material for analysis of a subject and wherein each value indicates a respective degree of importance of a corresponding data segment in the analysis.

9. The system of claim 7, wherein the priority module is further configured to base each value upon an expectation of success of retrieving the data segment associated with the value from a corresponding data source.

10. The system of claim 7, wherein the priority module is further configured to base each value upon an expected resource expenditure of retrieving the data segment associated with the value from a corresponding data source.

11. The system of claim 7, wherein the critical resource constraint is at least one of a resource budget or a critical time constraint.

12. The system of claim 7, wherein the processor is further configured to add additional slots to the slot map and to repeat the prioritizing for the additional slots.