Fault-tolerant data stream processing
US11297123B1 · kind B1 · utility
Assignee
Inventor
Key dates
| Filing date | Dec 11, 2020 |
| Grant date | Apr 5, 2022 |
| Priority date | — |
| Expiry date | Dec 11, 2040 |
Classification
- Technology area (CPC H)Electricity
- CPC primaryH04L65/756
- WIPO fieldDigital communication
- WIPO sectorElectrical engineering
Abstract
A method includes generating key assignment data indicating assignment of keys to a plurality of feed receiver modules, and processing a plurality of incoming messages via the plurality of feed receiver modules based on the key assignment data. Each of the plurality of feed receiver modules receives a proper subset of the plurality of incoming messages based on the key assignment data, and maintains a queue that includes messages of the proper subset that compare favorably to a time window. Each of the plurality of feed receiver modules identifies owned ones of the proper subset of messages having keys included in an owned subset of keys based on the key assignment data, and emits only the owned ones of the proper subset of messages.
Source: USPTO / EPO open patent data. Objective bibliographic and citation counts.