Method and system for processing raw financial data streams to produce and distribute structured and validated product offering objects

• US 10,007,727 B2
• Filed: 03/10/2014
• Issued: 06/26/2018
• Est. Priority Date: 08/04/2000
• Status: Active Grant

• Current Assignee: Goldman Sachs & Co. LLC (Goldman Sachs Group Incorporated)
• Original Assignee: Goldman Sachs & Co. LLC (Goldman Sachs Group Incorporated)
• Inventors: Smith, Andrew J. R., Thomas, Deane, Cowen, Randolph
• Primary Examiner(s): Survillo, Oleg
• Application Number:
  US14/202,954
• Publication Number:
  US 20140304284A1
• Time in Patent Office: 1,569 Days
• Field of Search: 709231
• CPC Class Codes: G06F 16/95 Retrieval from the web
• CPC Class Codes: G06Q 40/00 Finance; Insurance; Tax strategies; Processing of corporate or income taxes
• CPC Class Codes: G06Q 40/04 Trading; Exchange, e.g. stocks, commodities, derivatives or currency exchange
• CPC Class Codes: G06Q 40/06 Asset management; Financial planning or analysis
• CPC Class Codes: H04L 12/1859 adapted to provide push services, e.g. data channels
• CPC Class Codes: H04L 12/1895 for short real-time information, e.g. alarms, notifications, alerts, updates
• CPC Class Codes: H04L 41/0604 using filtering, e.g. reduction of information by using priority, element types, position or time
• CPC Class Codes: H04L 67/55 Push-based network services

Abstract

A real time information manager which processes raw data from data providers, such as feeds of current information about financial product offerings, is provided. Raw data objects received from various data providers are analyzed, formatted, and a current version of each unique data object is stored in an object storage pool. Information about the state of each objects is transmitted on a particular output data channel in accordance with the type of object. A subscriber process can access one or more of the data channels and utilize the broadcast data. In one configuration, one or more client managers are provided which subscribe to particular data channels and serve as an intermediary between the real time information manager and sets of clients.

Claims

1. A computerized method comprising:

subscribing, by a processor, to a data stream, wherein the data stream includes one or more objects obtained from a content provider over an Internet connection;

generating, by the processor, a user profile that determines how the one or more objects will be organized and viewed, the user profile comprising one or more folders, wherein each of the one or more folders comprises a set of attributes that describe data content and how to manipulate the data content, wherein the set of attributes comprises (i) configuration and initialization data that define one or more Java classes that represent the folder, and (ii) display attributes specifying how the data content is to be displayed;

receiving a snapshot of the one or more objects in the data stream;

storing, by the processor, the snapshot of the one or more objects in an object pool;

receiving, from a client manager, an event comprising modifications to the one or more objects in the object pool;

modifying, by the processor, the one or more objects in the snapshot with the modifications received in the event; and

displaying the one or more objects in accordance with the display attributes of the user profile.

2. The computerized method of claim 1, further comprising:

receiving at least one filter or rule relating to the one or more objects in the data stream, wherein the snapshot of the one or more objects in the data stream is constrained by the at least one filter or rule.

3. The computerized method of claim 1, wherein the set of attributes further comprises:

subscriptions to one or more data streams;

content filters; and

permissions.

4. The computerized method of claim 1, wherein the one or more objects are formatted, wherein the one or more formatted objects of the event are derived from a raw event in accordance with formatting rules.

5. The computerized method of claim 1, wherein the event is received by a queue manager, wherein the queue manager is configured to continually execute aggregation procedures.

6. The computerized method of claim 1, wherein a rate at which the one or more objects are received is specific to each client, wherein the rate is determined based at least on network travel time to the client and processing speed of the client.

7. The computerized method of claim 1, wherein the event is a price change of one of the one or more objects.

8. The computerized method of claim 7, wherein the user profile includes one or more folders, and wherein the event includes an update event for a first folder in the one or more folders, an add event for a second folder of the one or more folders, and a delete event for a third folder of the one or more folders.

9. A non-transitory, computer-readable medium comprising instructions that, when executed by one or more processors, cause a machine to:

subscribe to a data stream, wherein the data stream includes one or more objects obtained from a content provider over an Internet connection;

generate a user profile that determines how the one or more objects will be organized and viewed, the user profile comprising one or more folders, wherein each of the one or more folders comprises a set of attributes that describe data content and how to manipulate the data content, wherein the set of attributes comprises (i) configuration and initialization data that define one or more Java classes that represent the folder, and (ii) display attributes specifying how the data content is to be displayed;

receive a snapshot of the one or more objects in the data stream;

store the snapshot of the one or more objects in an object pool;

receive an event comprising modifications to the one or more objects in the object pool;

modify the one or more objects in the snapshot with the modifications received in the event; and

display the one or more objects in accordance with the display attributes of the user profile.

10. The non-transitory, computer-readable medium of claim 9, wherein the non-transitory, computer-readable medium comprises instructions that, when executed by the one or more processors, further cause the machine to receive at least one filter or rule relating to the one or more objects in the data stream, wherein the snapshot of the one or more objects in the data stream is constrained by the at least one filter or rule.

11. The non-transitory, computer-readable medium of claim 9, wherein the set of attributes further comprises:

subscriptions to one or more data streams;

content filters; and

permissions.

12. The non-transitory, computer-readable medium of claim 9, wherein the one or more objects are formatted, wherein the one or more formatted objects of the event are derived from a raw event in accordance with formatting rules.

13. The non-transitory, computer-readable medium of claim 9, wherein the event is received by a queue manager, wherein the queue manager is configured to continually execute aggregation procedures.

14. The non-transitory, computer-readable medium of claim 9, wherein a rate at which the one or more objects are received is specific to each client, wherein the rate is determined based at least on network travel time to the client and processing speed of the client.

15. The non-transitory, computer-readable medium of claim 9, wherein the event is a price change of one of the one or more objects.

16. The non-transitory, computer-readable medium of claim 15, wherein the user profile includes one or more folders, and wherein the event includes an update event for a first folder in the one or more folders, an add event for a second folder of the one or more folders, and a delete event for a third folder of the one or more folders.

17. A system comprising:

at least one processing device configured to;

subscribe to a data stream, wherein the data stream includes one or more objects obtained from a content provider over an Internet connection;

generate a user profile that determines how the one or more objects will be organized and viewed, the user profile comprising one or more folders, wherein each of the one or more folders comprises a set of attributes that describe data content and how to manipulate the data content, wherein the set of attributes comprises (i) configuration and initialization data that define one or more Java classes that represent the folder, and (ii) display attributes specifying how the data content is to be displayed;

receive a snapshot of the one or more objects in the data stream;

store the snapshot of the one or more objects in an object pool;

receive an event comprising modifications to the one or more objects in the object pool; and

modify the one or more objects in the snapshot with the modifications received in the event; and

a display configured to display the one or more objects in accordance with the display attributes of the user profile.

18. The system of claim 17, wherein the event is received by a queue manager, wherein the queue manager is configured to continually execute aggregation procedures.

19. The system of claim 17, wherein the at least one processing device is further configured to:

receive at least one filter or rule relating to the one or more objects in the data stream, wherein the snapshot of the one or more objects in the data stream is constrained by the at least one filter or rule.

20. The system of claim 17, wherein the set of attributes further comprises:

subscriptions to one or more data streams;

content filters; and

permissions.