System and method for aggregating market data of financial interests
Embodiments described herein relate to systems, methods, and computer readable instructions for processing data in financial interests, using automated electronic systems configured for aggregating market data relating to financial interests across multiple networked venues, including order books, venues, marketplaces, exchanges, alternative trading systems, and/or other markets, and/or various types thereof. Embodiments described herein may provide a consolidated view of market data specific to a market participant that may include generic data visible and accessible to other market participants and specific data visible and accessible only by the market participant.
1. A method for distributing event data received from a plurality of data feeds implemented by a computer system comprising a processor and at least one network interface, the method comprising:
receiving, over the at least one network interface, a plurality of data feeds from a plurality of remote input data sources, including at least one data feed comprising public data visible to a plurality of participants, and data feeds comprising data generated by a plurality of management systems of the plurality of participants, the plurality of data feeds comprising a plurality of events, said data feeds including a first data feed provided by a first user;
determining and applying to the plurality of events, by the processor, latency offsets for each event of the plurality of events based on times of receipt of events by the processor, wherein determining the latency offsets comprise using an anchor point associated with two of the plurality of data feeds to determine a latency offset for one of the two data feeds;
queuing, by the processor, the plurality of events based on the determined latency offsets; and
generating and transmitting, using the processor, a consolidated view of the queued plurality of events to the plurality of participants, the consolidated view being renderable on a display of participant data processing systems, wherein the consolidated view includes events from the public data and events from the data generated by the plurality of management systems, the plurality of participants including the first user, the consolidated view thereby including events from the first data feed provided by the first user.
2. The method of claim 1 , wherein generating the consolidated view comprises selecting data based on an identifier associated with the participant receiving the consolidated view.
3. The method of claim 1 , wherein the plurality of participants comprises market participants, and the management system comprises an order management system or execution management system.
4. The method of claim 1 , wherein the anchor point comprises a predefined key.
5. The method of claim 1 , wherein a first one of the two data feeds is a less dense data feed and a second one of the two data feeds is a more dense data feed, and determining the latency offset for one of the two data feeds comprises correlating an event in the less dense data feed to an event in the more dense data feed using the anchor point and computing a relative timestamp offset between the less dense data feed and the more dense data feed.
6. A system for distributing event data received from a plurality of data feeds, the system comprising:
at least one network interface; and
a processor configured to enable:
receiving, over the at least one network interface, a plurality of data feeds from a plurality of remote input data sources, including at least one data feed comprising public data visible to a plurality of participants, and data feeds comprising data generated by a plurality of management systems of the plurality of participants, the plurality of data feeds comprising a plurality of events said data feeds including a first data feed provided by a first user;
determining and applying to the plurality of events, latency offsets for each event of the plurality of events based on times of receipt of events by the processor, wherein determining the latency offsets comprises using an anchor point associated with two of the plurality of data feeds to determine a latency offset for one of the two data feeds;
queuing the plurality of events based on the determined latency offsets; and
generating and transmitting a consolidated view of the queued plurality of events to the plurality of participants, the consolidated view being renderable on a display of participant data processing systems, wherein the consolidated view includes events from the public data and events from the data generated by the plurality of management systems, the plurality of participants including the first user, the consolidated view thereby including events from the first data feed provided by the first user.
7. The system of claim 6 , wherein generating the consolidated view comprises selecting data based on an identifier associated with the participant receiving the consolidated view.
8. The system of claim 6 , wherein the plurality of participants comprises market participants, and the management system comprises an order management system or execution management system.
9. The system of claim 6 , wherein the anchor point comprises a predefined key.
10. The system of claim 6 , wherein a first one of the two data feeds is a less dense data feed and a second one of the two data feeds is a more dense data feed, and determining the latency offset for one of the two data feeds comprises correlating an event in the less dense data feed to an event in the more dense data feed using the anchor point and computing a relative timestamp offset between the less dense data feed and the more dense data feed.
11. A non-transitory computer-readable medium bearing code which, when executed by at least one processor in a computing system, causes the system to implement the method of:
receiving, over at least one network interface, a plurality of data feeds from a plurality of remote input data sources, including at least one data feed comprising public data visible to a plurality of participants, and data feeds comprising data generated by a plurality of management systems of the plurality of participants, the plurality of data feeds comprising a plurality of events, said data feeds including a first data feed provided by a first user;
determining and applying to the plurality of events, by the processor, latency offsets for each event of the plurality of events based on times of receipt of events by the processor, wherein determining the latency offsets comprises using an anchor point associated with two of the plurality of data feeds to determine a latency offset for one of the two data feeds;
queuing, by the processor, the plurality of events based on the determined latency offsets; and
generating and transmitting, using the processor, a consolidated view of the queued plurality of events to the plurality of participants, the consolidated view being renderable on a display of participant data processing systems, wherein the consolidated view includes events from the public data and events from the data generated by the plurality of management systems, the plurality of participants including the first user, the consolidated view thereby including events from the first data feed provided by the first user.