Simultaneous analysis of multiple data sources by sychronization

• US 8,332,455 B2
• Filed: 06/06/2002
• Issued: 12/11/2012
• Est. Priority Date: 06/06/2002
• Status: Active Grant

• Current Assignee: Kyndryl Incorporated (Kyndryl Holdings, Inc.)
• Original Assignee: International Business Machines Corporation
• Inventors: Hooks, Charles Gordon
• Primary Examiner(s): Nawaz, Asad
• Assistant Examiner(s): Nano, Sargon
• Application Number:
  US10/165,092
• Publication Number:
  US 20030229663A1
• Time in Patent Office: 3,841 Days
• Field of Search: 709/202, 709/203, 709/205, 709/232, 709/246, 709/201, 707/102, 707/2, 707/206, 707/999.2, 707/999.203, 707/999.206
• US Class Current: 709/201
• CPC Class Codes: H04L 69/08 Protocols for interworking; Protocol conversion

Abstract

An apparatus and method is disclosed for processing of multiple sources of data in a single execution process to synchronize the data to be analyzed by multiple analysis routines. A control program is given the criteria for each of the analysis routines and then reads data from each source meeting the criteria, converting the data from each source to a common format, controlling the analysis routines for each source for time synchronization of the data from the multiple sources and executing each analysis routine in time order. Specifically the following subroutines are used: (1) a routine to read and process a set of controls to describe data by time and type for each analysis routine; (2) a routine to read and process a set of controls to describe the sources of input; (3) a routine for reading data from each of the sources of input a record at a time, deciding whether the time and type for the record is requested for the current analysis, and if not, reading another record or, if so, setting up to process and return the current time and type of record for the source in a common format; and (4) a routine to decide which time from the current record for each source is the earliest and then execute the appropriate analysis by type of data requested for that source record by calling the appropriate analysis routine.

Claims

1. A method for processing records from multiple source files, the method comprising:

a computer receiving a data request comprising a time interval and a data type;

the computer selecting records in the source files responsive to the data request;

the computer placing the selected records in a common time order format; and

the computer calling analysis routines to process the selected records in the common time order format;

wherein the common time order format comprises a time index and a data value of the data type received in the data request.

2. The method of claim 1 further comprising:

the computer summarizing the results of each analysis routine after all records have been analyzed.

3. The method of claim 1 further comprising:

the computer storing control data for each analysis routine.

4. The method of claim 1 further comprising:

the computer reading a source description.

5. The method of claim 1 wherein selecting records in the source files comprises:

the computer calling a read routine to read the records in each source file, wherein each read routine comprises instructions for reading the format of the source file;

the computer identifying each record in the source files responsive to the time interval in the data request; and

the computer verifying that each identified record includes data responsive to the data type in the data request.

6. An apparatus for processing records from multiple source files, the apparatus comprising:

a processor;

a storage medium connected to the processor;

a synchronization program residing in the storage medium; and

source files residing in the storage medium;

wherein the synchronization program is operable to cause the processor to

receive a data request comprising a time interval and a data type;

select records in the source files responsive to the data request;

place the selected records in a common time order format; and

call analysis routines to process the selected records in the common time order format;

wherein the common time order format comprises a time index and a data value of the data type received in the data request.

7. The apparatus of claim 6 wherein the synchronization program further causes the processor to summarize the results of each analysis routine after all records have been analyzed.

8. The apparatus of claim 6 wherein the synchronization program further causes the processor to store control data for each analysis routine.

9. The apparatus of claim 6 wherein the synchronization program further causes the processor to read a source description.

10. The apparatus of claim 6 wherein the synchronization program further causes the processor to call a read routine to read the records in each source file, wherein each read routine comprises instructions for reading the format of the source file, identifying each record in the source files responsive to the time interval in the data request, and verifying that each identified record includes data responsive to the data type in the data request.

11. An apparatus for processing records from multiple source files, the apparatus comprising:

one or more processors, one or more computer readable storage devices, and one or more computer readable memories;

computer program instructions stored on at least one computer readable storage device for execution by at least one processor via at least one computer readable memory for receiving a data request comprising a time interval and a data type;

computer program instructions stored on at least one computer readable storage device for execution by at least one processor via at least one computer readable memory for selecting records in the source files responsive to the data request;

computer program instructions stored on at least one computer readable storage device for execution by at least one processor via at least one computer readable memory for placing the selected records in a common format in time order; and

computer program instructions stored on at least one computer readable storage device for execution by at least one processor via at least one computer readable memory for calling analysis routines to process the selected records in time order;

wherein the common time order format comprises a time index and a data value of the data type received in the data request.

12. The apparatus of claim 11 further comprising:

computer program instructions stored on at least one computer readable storage device for execution by at least one processor via at least one computer readable memory for summarizing the results of each analysis routine after all records have been analyzed.

13. The apparatus of claim 11 further comprising:

computer program instructions stored on at least one computer readable storage device for execution by at least one processor via at least one computer readable memory for storing control data for each analysis routine.

14. The apparatus of claim 11 further comprising:

computer program instructions stored on at least one computer readable storage device for execution by at least one processor via at least one computer readable memory for reading a source description.

15. The apparatus of claim 11 wherein the means for selecting records comprises:

computer program instructions stored on at least one computer readable storage device for execution by at least one processor via at least one computer readable memory for reading the records in each source file;

computer program instructions stored on at least one computer readable storage device for execution by at least one processor via at least one computer readable memory for identifying each record in the source files responsive to the time interval in the data request; and

computer program instructions stored on at least one computer readable storage device for execution by at least one processor via at least one computer readable memory for verifying that each identified record includes data responsive to the data type in the data request.

16. The apparatus of claim 11 further comprising:

computer program instructions stored on at least one computer readable storage device for summarizing the results of each analysis routine after all records have been analyzed.

17. The apparatus of claim 11 further comprising:

computer program instructions stored on at least one computer readable storage device for storing control data for each analysis routine.

18. The apparatus of claim 11 further comprising:

computer program instructions stored on at least one computer readable storage device for reading a source description.

19. The apparatus of claim 11 wherein the means for selecting records comprises:

computer program instructions stored on at least one computer readable storage device for reading the records in each source file;

computer program instructions stored on at least one computer readable storage device for identifying each record in the source files responsive to the time interval in the data request; and

computer program instructions stored on at least one computer readable storage device for verifying that each identified record includes data responsive to the data type in the data request.

20. A computer program product for processing records from multiple source files, the computer program product comprising:

one or more computer readable storage devices;

computer program instructions stored on at least one computer readable storage device for receiving a data request comprising a time interval and a data type;

computer program instructions stored on at least one computer readable storage device for selecting records in the source files responsive to the data request;

computer program instructions stored on at least one computer readable storage device for placing the selected records in a common format in time order; and

computer program instructions stored on at least one computer readable storage device for calling analysis routines to process the selected records in time order;

wherein the common time order format comprises a time index and a data value of the data type received in the data request.