Method, device and computer program product for data stream processing
US11157178B2 · kind B2 · utility
Assignee
Inventors
Key dates
| Filing date | Apr 25, 2019 |
| Grant date | Oct 26, 2021 |
| Priority date | — |
| Expiry date | Dec 24, 2039 |
Classification
- Technology area (CPC G)Physics
- CPC primaryG06F2201/84
- WIPO fieldComputer technology
- WIPO sectorElectrical engineering
Abstract
Embodiments of the present disclosure relate to a method, device and computer program product for data stream processing. The method comprises activating, in response to receiving a starting first predefined tag in a first input data stream from a first data source, a duplicate process of a process by duplicating a state of the process to the duplicate process. The method further comprises processing, by the duplicate process, only a data unit before an ending second predefined tag in a second input data stream from a second data source without interruption of processing of the first and second input data streams by the process. The second data source differs from the first data source. The method further comprises creating a snapshot of the duplicate process for recovery of the process due to failure in response to receiving the ending second predefined tag in the second input data stream.
Source: USPTO / EPO open patent data. Objective bibliographic and citation counts.