Adapting unreliable data sink to reliable stream
US12200052B1 · kind B1 · utility
Assignee
Inventors
Key dates
| Filing date | Nov 3, 2023 |
| Grant date | Jan 14, 2025 |
| Priority date | — |
| Expiry date | Nov 3, 2043 |
Classification
- Technology area (CPC H)Electricity
- CPC primaryH04L67/1097
- WIPO fieldDigital communication
- WIPO sectorElectrical engineering
Abstract
According to at least one embodiment, a method, a computer system, and a computer program product for handling an unreliable data sink is provided. The present invention may include reading, continuously, via a stream processor, a batch of data entering the stream processor via a reliable input stream, the stream processor comprising a daisy chain of sink nodes, wherein a first sink node is a primary sink node and a subsequent plurality of sink nodes in the daisy chain are fallback sink nodes; outputting processed data to a non-streaming target system; upon completion of the processed data to the non-streaming target system, invoking an asynchronous callback function listing successful and failed record IDs of the processed data; and passing the failed records to a first fallback sink within the daisy chain, while the primary sink node concurrently continues submitting new batches of data to the non-streaming target system.
Source: USPTO / EPO open patent data. Objective bibliographic and citation counts.