Accumulating results from batch processing and resuming execution of a data integration flow with the accumulated results passed in
US10831774B2 · kind B2 · utility
Assignee
Inventors
Key dates
| Filing date | Sep 5, 2018 |
| Grant date | Nov 10, 2020 |
| Priority date | — |
| Expiry date | Mar 28, 2039 |
Classification
- Technology area (CPC G)Physics
- CPC primaryG06F16/2386
- WIPO fieldComputer technology
- WIPO sectorElectrical engineering
Abstract
Passing a result of batch processing into a data integration flow is provided. Each data record of a plurality of data records corresponding to a specified data record collection is processed within a different thread of a different execution branch in parallel. At an end of each processing of each different execution branch, a new value is computed for each processed data record based on a previously stored value and an execution branch context for each processed data record. It is determined whether all data records in the plurality of data records have been processed. In response to determining that all of the data records in the plurality of data records have been processed, a data accumulation object corresponding to the batch processing is updated within a data assembly context based on a computed new value for each processed data record to form an updated data assembly context.
Source: USPTO / EPO open patent data. Objective bibliographic and citation counts.