Simultaneous analysis of multiple data sources by sychronization

• US 20030229663A1
• Filed: 06/06/2002
• Published: 12/11/2003
• Est. Priority Date: 06/06/2002
• Status: Active Grant

• Current Assignee: Kyndryl Incorporated
• Original Assignee: International Business Machines Corporation
• Inventors: Hooks, Charles Gordon
• Granted Patent: US 8,332,455 B2
• Time in Patent Office: Days
• 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 multiple sources of data by multiple analysis routines comprising:

identifying criteria;

identifying records responsive to the criteria;

placing the records in a common time order format; and

calling responsive analysis routines to each record in time order.

2. The method of claim 1 further comprising:

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

3. The method of claim 1 further comprising:

reading control data for each analysis routine.

4. The method of claim 1 further comprising:

storing control data for each analysis routine.

5. The method of claim 1 further comprising:

reading a source description.

6. The method of claim 1 further comprising:

initializing a source by positioning at the first record requested by time and type.

7. The method of claim 1 further comprising:

processing data from a source with the earliest time record.

8. The method of claim 1 further comprising:

executing analysis routines for the source with the earliest time record.

9. An apparatus for processing multiple sources of data by multiple analysis routines, comprising:

a programmable processor;

a network connected to the programmable processor;

a storage medium in the programmable processor;

a synchronization program residing in the storage medium;

a data source connected to the network; and

wherein the synchronization program calls places each record in the data source in time order to be analyzed by each analysis routine for which the record meets a criteria.

10. The apparatus of claim 9 wherein the synchronization program further causes the processor to identify criteria.

11. The apparatus of claim 9 wherein the synchronization program further causes the processor to identify records responsive to the criteria.

12. The apparatus of claim 9 wherein the synchronization program further causes the processor to place the records in a common time order format.

13. The apparatus of claim 9 wherein the synchronization program further causes the processor to call responsive analysis routines to each record in time order.

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

15. The apparatus of claim 9 wherein the synchronization program further causes the processor to read control data for each analysis routine.

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

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

18. The apparatus of claim 9 wherein the synchronization program further causes the processor to initialize a source by positioning at the first record requested by time and type.

19. The apparatus of claim 9 wherein the synchronization program further causes the processor to process data from a source with the earliest time record.

20. The apparatus of claim 9 wherein the synchronization program further causes the processor to execute an analysis routine for the source with the earliest time record.

21. An apparatus for processing multiple sources of data by multiple analysis routines comparing a plurality of sources, comprising:

means for reading criteria;

means for placing all records to be processed by the multiple analysis routines into a common format in time order;

means for calling each record in time order to be processed.

22. The apparatus of claim 21 further comprising:

means for identifying criteria.

23. The apparatus of claim 21 further comprising:

means for identifying records responsive to the criteria.

24. The apparatus of claim 21 further comprising:

means for placing the records in a common time order format.

25. The apparatus of claim 21 further comprising:

means for calling responsive analysis routines to each record in time order.

26. The apparatus of claim 21 further comprising:

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

27. The apparatus of claim 21 further comprising:

means for reading control data for each analysis routine.

28. The apparatus of claim 21 further comprising:

means for storing control data for each analysis routine.

29. The apparatus of claim 21 further comprising:

means for reading a source description.

30. The apparatus of claim 21 further comprising:

means for initializing a source by positioning at the first requested record by time and type.

31. The apparatus of claim 21 further comprising:

means for processing data from a source with the earliest time record.

32. The apparatus of claim 21 further comprising:

means for executing analysis routines for the source with the earliest time record.