CPC G06F 16/2358 (2019.01) [G06F 16/214 (2019.01); G06F 16/24568 (2019.01); G06F 16/27 (2019.01); G06F 16/273 (2019.01); G06F 21/6218 (2013.01)] | 16 Claims |
1. A method comprising:
subscribing a persistent data store to receive files associated with a source database, a file comprising log data associated with a change event;
extracting a plurality of change events from the received files, without consideration to a time stamp of a change event or the order in which the plurality of change events are received;
mapping, in parallel and out of order, a set of transactions comprising the plurality of change events from the received files, the parallel mapping taking into consideration dependencies between the plurality of change events;
collating the set of mapped transactions to create an ordered set of change events for processing; and
providing access to the ordered set of change events to apply the ordered set of change events to a target database.
|