Parallel processing of changes in a distributed system
AssigneeSap SE
InventorMichael Haberkorn
Life of this patent
Estimating the term…
Abstract
Systems and methods include reception of a request for changed data of an object from a subscriber, determination of a logging table associated with the object and comprising a plurality of logging table entries, determination of a pointer to a last-processed entry of the logging table based on the object and the subscriber, definition of a plurality of sub-portions of logging table entries subsequent to the last-processed entry, and reconstruction and transfer of first data associated with a first one of the plurality of sub-portions to the subscriber using a first process, and reconstruction and transfer, in parallel with the first process, second data associated with a second one of the plurality of sub-portions to the subscriber using a second process.
Claims20
A system comprising:
- a memory storing processor-executable process steps;
- a processing unit to execute the processor-executable process steps to cause the system to:
- receive a request for changed data of an object from a subscriber;
- determine a logging table associated with the object and comprising a plurality of logging table entries;
- determine a pointer to a last-processed entry of the logging table based on the object and the subscriber;
- define a plurality of sub-portions of logging table entries subsequent to the last-processed entry;
- and
- reconstruct and transfer first data associated with a first one of the plurality of sub-portions to the subscriber using a first process;
- and
- reconstruct and transfer second data associated with a second one of the plurality of sub-portions to the subscriber using a second process,
- wherein the first process and the second process operate in parallel.
A computer-implemented method comprising:
- receiving a request for changed data of an object from a subscriber;
- determining a logging table associated with the object and comprising a plurality of logging table entries;
- determining a pointer to a last-processed entry of the logging table based on the object and the subscriber;
- defining a plurality of sub-portions of logging table entries subsequent to the last-processed entry;
- and
- reconstructing and transferring first data associated with a first one of the plurality of sub-portions to the subscriber using a first process;
- and
- reconstructing and transferring, in parallel with the first process, second data associated with a second one of the plurality of sub-portions to the subscriber using a second process.
A system comprising:
- a subscriber system;
- a source database system storing a database table, the source database system to:
- receive a request for changed data of the database table from the subscriber system;
- determine a logging table associated with the database table and comprising a plurality of logging table entries;
- determine a pointer to a last-processed entry of the logging table based on the database table and the subscriber;
- define a plurality of sub-portions of logging table entries subsequent to the last-processed entry;
- and
- reconstruct and transfer first data associated with a first one of the plurality of sub-portions to the subscriber system using a first process;
- and
- reconstruct and transfer second data associated with a second one of the plurality of sub-portions to the subscriber system using a second process,
- wherein the first process and the second process operate in parallel.
Dependencies are inferred from the claim text.