Creating event streams from raw data

• US 9,824,112 B1
• Filed: 02/13/2015
• Issued: 11/21/2017
• Est. Priority Date: 02/18/2014
• Status: Active Grant

• Current Assignee: Google LLC (Alphabet Inc.)
• Original Assignee: Google Inc. (Alphabet Inc.)
• Inventors: Gardner, III, Alan Lee, Aharony, Nadav, Sumter, George Cody
• Primary Examiner(s): Pham, Tuan A
• Application Number:
  US14/622,769
• Time in Patent Office: 1,012 Days
• Field of Search: None
• CPC Class Codes: G06F 16/24568 Data stream processing; Continuous queries

Abstract

The disclosure includes a system and method for creating event streams from raw data. The system includes a processor and a memory storing instructions that when executed cause the system to: receive a first event and a second event associated with a first user from a first user device; receive a third event associated with a second user from a second user device; determine one or more overlapping activities between the first event and the third event; update the first event using the third event to generate a first update event; update the third event using the first event to generate a second update event; generate a first event stream that includes the first update event and the second event for the first user; and generate a second event stream that includes the second update event for the second user.

Claims

1. A computer-implemented method comprising:

receiving, using one or more processors, a first signal stream from a hardware sensor associated with a first user device of a first user;

receiving, using the one or more processors, a second signal stream from a virtual detector associated with the first user device of the first user, the second signal stream includes software data related to software operational on the first user device;

defining, using the one or more processors, a first event for the first user based on the first signal stream and the second signal stream;

polling, using the one or more processors, for a second user device within proximity to the first user based on a second user associated with the second user device being associated with the first user on a social graph, the second user device is within proximity to the first user when a distance between the second user device and the first user is shorter than a predetermined distance;

receiving, using the one or more processors, a second event associated with the second user from the second user device;

determining, using the one or more processors, one or more overlapping activities between the first event and the second event;

updating, using the one or more processors, the first event using the second event to generate a first update event responsive to a determination of the one or more overlapping activities; and

generating, using the one or more processors, a first event stream that includes the first update event for the first user.

2. The method of claim 1, wherein determining the one or more overlapping activities comprises:

retrieving social network data from a social network server;

identifying an association between the first user and the second user based on the social network data; and

determining the one or more overlapping activities based on the association between the first user and the second user.

3. The method of claim 1, wherein the second event includes information about the first user being associated with the second event and the first user device lacks capabilities for detecting the second user device.

4. The method of claim 1, further comprising sending the first event stream to the first user device.

5. The method of claim 1, further comprising:

receiving a signal stream associated with the first user;

saving data from the signal stream that indicates a change of state;

identifying one or more activities associated with the first user from the filtered stream; and

aggregating the one or more activities to define the first event associated with the first user.

6. The method of claim 1, wherein each of the one or more overlapping activities includes a social aspect, an attention aspect, a mobility aspect, a mood aspect, a biomeasure aspect, a health and wellness aspect and a contextual aspect.

7. The method of claim 1, further comprising:

detecting a presence of a third device associated with the first user device at a first timestamp;

detecting a presence of the third device associated with the second user device at a second timestamp; and

responsive to a time difference between the first timestamp and the second timestamp being within a predetermined threshold, determining that the first user device and the second user device are within proximity of each other, wherein the first user device and the second user device are within proximity if a distance between the first and second user devices is shorter than a predetermined distance.

8. The method of claim 1, wherein the one or more overlapping activities are performed together by the first user and the second user.

9. The method of claim 1, further comprising generating analytics data associated with the one or more overlapping activities.

10. The method of claim 1, further comprising posting content to a social network that includes content captured in association with overlapping activities.

11. The method of claim 1, further comprising determining that the first user owns a third user device based on a distance between the first user device and the third user device is shorter than a predetermined distance responsive to exceeding a threshold time period.

12. A computer program product comprising a non-transitory computer-readable medium including a computer readable program, wherein the computer readable program when executed on a computer causes the computer to:

receive a first signal stream from a hardware sensor associated with a first user device of a first user;

receive a second signal stream from a virtual detector associated with the first user device of the first user, the second signal stream includes software data related to software operational on the first user device;

define a first event for the first user based on the first signal stream and the second signal stream;

poll for a second user device within proximity to the first user based on a second user associated with the second user device being associated with the first user on a social graph, the second user device is within proximity to the first user when a distance between the second user device and the first user is shorter than a predetermined distance;

receive a second event associated with the second user from the second user device;

determine one or more overlapping activities between the first event and the second event;

update the first event using the second event to generate a first update event responsive to a determination of the one or more overlapping activities; and

generate a first event stream that includes the first update event for the first user.

13. The computer program product of claim 12, wherein determining the one or more overlapping activities comprises:

retrieving social network data from a social network server;

identifying an association between the first user and the second user based on the social network data; and

determining the one or more overlapping activities based on the association between the first user and the second user.

14. The computer program product of claim 12, wherein the second event includes information about the first user being associated with the second event and the first user device lacks capabilities for detecting the second user device.

15. The computer program product of claim 12, wherein the computer readable program when executed on the computer causes the computer to:

receive a signal stream associated with the first user;

save data from the signal stream that indicates a change of state;

identify one or more activities associated with the first user from the filtered stream; and

aggregate the one or more activities to define the first event associated with the first user.

16. The computer program product of claim 12, wherein the computer readable program when executed on the computer causes the computer to also send the first event stream to the first user device.

17. The computer program product of claim 12, wherein each of the one or more overlapping activities includes a social aspect, an attention aspect, a mobility aspect, a mood aspect, a biomeasure aspect, a health and wellness aspect and a contextual aspect.

18. The computer program product of claim 12, wherein the computer readable program when executed on the computer causes the computer to also:

detect a presence of a third device associated with the first user device at a first timestamp;

detect a presence of the third device associated with the second user device at a second timestamp; and

responsive to a time difference between the first timestamp and the second timestamp being within a predetermined threshold, determine that the first user device and the second user device are within proximity of each other, wherein the first user device and the second user device are within proximity if a distance between the first and the second user devices is shorter than a predetermined distance.