Data aggregation platform

• US 8,725,462 B2
• Filed: 05/13/2011
• Issued: 05/13/2014
• Est. Priority Date: 05/13/2011
• Status: Active Grant

• Current Assignee: Fujitsu Limited
• Original Assignee: Fujitsu Limited
• Inventors: Jain, Jawahar, Marvit, David Loren, Adler, B. Thomas, Balakrishnan, Rajalakshmi, Gilman, Alexander, Stergiou, Stergios, Braun, Albert C., Reinhardt, Albert H. M.
• Primary Examiner(s): BHAT, ADITYA S
• Application Number:
  US13/107,697
• Publication Number:
  US 20120290266A1
• Time in Patent Office: 1,096 Days
• Field of Search: 702/187
• US Class Current: 702/187
• CPC Class Codes: G16H 10/20 for electronic clinical trials or questionnaires
• CPC Class Codes: G16H 40/63 for local operation
• CPC Class Codes: G16H 40/67 for remote operation
• CPC Class Codes: G16H 50/20 for computer-aided diagnosis, e.g. based on medical expert systems
• CPC Class Codes: G16H 50/30 for calculating health indices; for individual health risk assessment
• CPC Class Codes: G16H 50/50 for simulation or modelling of medical disorders

Abstract

In particular embodiments, a method includes accessing an original data stream from a sensor, associating a timestamp with each of the samples in the data stream based on a system clock, and recording the original data stream with the associated timestamps.

Claims

1. A method comprising, by one or more processors associated with a mobile data aggregation system:

accessing, by one or more of the processors, a plurality of original data streams from a plurality of sensors, respectively, each of the original data streams comprising a series of samples that each represent a measurement of a stimulus sensed by the sensor that the original data stream is from, wherein each of one or more of the sensors associates original timestamps to the samples in its original data stream and its original data stream comprises the original timestamps with the samples, and wherein one or more of the sensors is affixed to a person'"'"'s body;

synchronizing, by one or more of the processors, the plurality of original data streams by overwriting the original timestamps associated with the samples in the original data streams with a system timestamp based on a system clock, the system clock operating independent of the plurality of sensors;

generating, by one or more of the processors, a derivative data stream from one or more of the original data streams using a meta-sensor to perform an operation on the data streams to generate a series of samples, wherein a system timestamp is associated with each of the samples in the derivative data stream based on the system clock; and

recording, by one or more of the processors, the derivative data stream and the original data streams with the synchronized system timestamps associated with their samples for correlation of the derivative data stream with one or more of the original data streams or with information outside the derivative and original data streams.

2. The method of claim 1, wherein recording the derivative data stream and the original data streams with the synchronized system timestamps comprises storing the original data streams as one or more binary decision diagrams (BDDs).

3. The method of claim 1, wherein each of the samples is recorded within a tuple.

4. The method of claim 1, further comprising:

transmitting the derivative data stream for correlation of the derivative data stream with one or more of the original data streams or with information outside the derivative and original data streams.

5. The method of claim 1, wherein accessing the plurality of original data streams comprises receiving the data streams across one or more wireless interfaces between the mobile data aggregation system and one or more of the sensors.

6. The method of claim 1, further comprising transmitting the original data streams with the synchronized system timestamps associated with their samples for the correlation of the original data streams with each other or with information outside the data streams.

7. The method of claim 6, wherein transmitting the original data streams with the synchronized system timestamps associated with their samples comprises transmitting the original data streams with the synchronized system timestamps associated with their samples to one or more web servers.

8. The method of claim 1, wherein one or more of the original data streams comprise physiological data of the person.

9. The method of claim 1, further comprising, by the mobile data aggregation system, using the synchronized system timestamps associated with the samples to correlate the original data streams with each other or with information outside the data streams.

10. The method of claim 9, further comprising, by the mobile data aggregation system, transmitting the synchronized system timestamps with a result generated by correlating the original data streams with each other or with information outside the data streams.

11. The method of claim 10, further comprising, by the mobile data aggregation system, transmitting a start time and a sampling frequency with the result generated by correlating the original data streams with each other or with information outside the data streams.

12. A mobile data aggregation system comprising:

one or more processors; and

a memory coupled to the processors comprising instructions executable by the processors, the processors operable when executing the instructions to;

access a plurality of original data streams from a plurality of sensors, respectively, each of the original data streams comprising a series of samples that each represent a measurement of a stimulus sensed by the sensor that the original data stream is from, wherein each of one or more of the sensors associates original timestamps to the samples in its original data stream and its original data stream comprises the original timestamps with the samples, and wherein one or more of the sensors is affixed to a person'"'"'s body;

synchronize the plurality of original data streams by overwriting the original timestamps associated with the samples in the original data streams with a system timestamp based on a system clock, the system clock operating independent of the plurality of sensors;

generate a derivative data stream from one or more of the original data streams using a meta-sensor to perform an operation on the data streams to generate a series of samples, wherein a system timestamp is associated with each of the samples in the derivative data stream based on the system clock; and

record the derivative data stream and the original data streams with the synchronized system timestamps associated with their samples for correlation of the derivative data stream with one or more of the original data streams or with information outside the derivative and original data streams.

13. The mobile data aggregation system of claim 12, wherein to record the derivative data stream and the original data streams with the synchronized system timestamps comprises to store them as one or more binary decision diagrams (BDDs).

14. The mobile data aggregation system of claim 12, wherein each of the samples is recorded within a tuple.

15. The mobile data aggregation system of claim 12, wherein the mobile data aggregation system is further operable when executing instructions to:

transmit the derivative data stream for correlation of the derivative data stream with one or more of the original data streams or with information outside the derivative and original data streams.

16. The mobile data aggregation system of claim 12, wherein to access the plurality of original data streams comprises to receive the data streams across one or more wireless interfaces between the mobile data aggregation system and one or more of the sensors.

17. The mobile data aggregation system of claim 12, wherein the mobile data aggregation system is further operable when executing instructions to transmit the original data streams with the synchronized system timestamps associated with their samples for the correlation of the original data streams with each other or with information outside the data streams.

18. The mobile data aggregation system of claim 17, wherein to transmit the original data streams with the synchronized system timestamps associated with their samples comprises to transmit the original data steams with the synchronized system timestamps associated with their samples to one or more web servers.

19. The mobile data aggregation system of claim 12, wherein one or more of the original data streams comprise physiological data of the person.

20. The mobile data aggregation system of claim 12, wherein the mobile data aggregation system is further operable when executing instructions to use the synchronized system timestamps associated with the samples to correlate the original data streams with each other or with information outside the data streams.

21. The mobile data aggregation system of claim 20, wherein the mobile data aggregation system is further operable when executing instructions to transmit the synchronized system timestamps with a result generated by correlating the original data streams with each other or with information outside the data streams.

22. The mobile data aggregation system of claim 21, wherein the mobile data aggregation system is further operable when executing instructions to transmit a start time and a sampling frequency with the result generated by correlating the original data streams with each other or with information outside the data streams.

23. One or more computer-readable non-transitory storage media embodying software that is operable when executed on a mobile data aggregation system to:

access a plurality of original data streams from a plurality of sensors, respectively, each of the original data streams comprising a series of samples that each represent a measurement of a stimulus sensed by the sensor that the original data stream is from, wherein each of one or more of the sensors associates original timestamps to the samples in its original data stream and its original data stream comprises the original timestamps with the samples, and wherein one or more of the sensors is affixed to a person'"'"'s body;

synchronize the plurality of original data streams by overwriting the original timestamps associated with the samples in the original data streams with a system timestamp based on a system clock, the system clock operating independent of the plurality of sensors;

generate a derivative data stream from one or more of the original data streams using a meta-sensor to perform an operation on the data streams to generate a series of samples, wherein a system timestamp is associated with each of the samples in the derivative data stream based on the system clock; and

record the derivative data stream and the original data streams with the synchronized system timestamps associated with their samples for correlation of the derivative data stream with one or more of the original data streams or with information outside the derivative and original data streams.

24. The media of claim 23, wherein to record the derivative data stream and the original data streams with the synchronized system timestamps comprises to store the original data streams as one or more binary decision diagrams (BDDs).

25. The media of claim 23, wherein each of the samples is recorded within a tuple.

26. The media of claim 23, the media embodying instructions that are further operable when executed to:

transmit the derivative data stream for correlation of the derivative data stream with one or more of the original data streams or with information outside the derivative and original data streams.

27. The media of claim 23, wherein to access the plurality of original data streams comprises to receive the data streams across one or more wireless interfaces between the mobile data aggregation system and one or more of the sensors.

28. The media of claim 23, the media embodying instructions that are further operable when executed to transmit the original data streams with the synchronized system timestamps associated with their samples for the correlation of the original data streams with each other or with information outside the data streams.

29. The media of claim 28, wherein to transmit the original data streams with the synchronized system timestamps associated with their samples comprises to transmit the original data streams with the synchronized system timestamps associated with their samples to one or more web servers.

30. The media of claim 23, wherein one or more of the original data streams comprise physiological data of the person.

31. The media of claim 23, the media embodying instructions that are further operable when executed to use the synchronized system timestamps associated with the samples to correlate the original data streams with each other or with information outside the data streams.

32. The media of claim 31, the media embodying instructions that are further operable when executed to transmit the synchronized system timestamps with a result generated by correlating the original data streams with each other or with information outside the data streams.

33. The media of claim 32, the media embodying instructions that are further operable when executed to transmit a start time and a sampling frequency with the result generated by correlating the original data streams with each other or with information outside the data streams.

34. A mobile data aggregation system comprising:

means for accessing a plurality of original data streams from a plurality of sensors, respectively, each of the original data streams comprising a series of samples that each represent a measurement of a stimulus sensed by the sensor that the original data stream is from, wherein each of one or more of the sensors associates original timestamps to the samples in its original data stream and its original data stream comprises the original timestamps with the samples, and wherein one or more of the sensors is affixed to a person'"'"'s body;

means for synchronizing the plurality of original data streams by overwriting the original timestamps associated with the samples in the original data streams with a system timestamp based on a system clock, the system clock operating independent of the plurality of sensors;

means for generating a derivative data stream from one or more of the original data streams using a meta-sensor to perform an operation on the data streams to generate a series of samples, wherein a system timestamp is associated with each of the samples in the derivative data stream based on the system clock; and

means for recording the derivative data stream and the original data streams with the synchronized system timestamps associated with their samples for correlation of the derivative data stream with one or more of the original data streams or with information outside the derivative and original data streams.

35. The system of claim 34, wherein the means for recording the derivative data stream and the original data streams with the synchronized system timestamps comprises means for storing the original data streams as one or more binary decision diagrams (BDDs).

36. The system of claim 34, wherein each of the samples is recorded within a tuple.

37. The system of claim 34, further comprising:

means for transmitting the derivative data stream for correlation of the derivative data stream with one or more of the original data streams or with information outside the derivative and original data streams.

38. The system of claim 34, wherein the means for accessing the plurality of original data streams comprises means for receiving the data streams across one or more wireless interfaces between the mobile data aggregation system and one or more of the sensors.

39. The system of claim 34, further comprising means for transmitting the original data streams with the synchronized system timestamps associated with their samples for the correlation of the original data streams with each other or with information outside the data streams.

40. The system of claim 39, wherein the means for transmitting the original data streams with the synchronized system timestamps associated with their samples comprises means for transmitting the original data streams with the synchronized system timestamps associated with their samples to one or more web servers.

41. The system of claim 34, wherein one or more of the original data streams comprise physiological data of the person.

42. The system of claim 34, further comprising means for using the synchronized system timestamps associated with the samples to correlate the original data streams with each other or with information outside the data streams.

43. The system of claim 42, further comprising, means for transmitting the synchronized system timestamps with a result generated by correlating the original data streams with each other or with information outside the data streams.

44. The system of claim 43, further comprising means for transmitting a start time and a sampling frequency with the result generated by correlating the original data streams with each other or with information outside the data streams.