Automatic parallelism tuning for apply processes

A non-transitory computer storage medium storing instructions which, when executed by one or more processors, cause performance of a method comprising the steps of:

• obtaining a plurality of change records;
• assigning at least one batch of change records to one or more apply processes in a set of active apply processes;
• periodically determining a first throughput value based on a number of processed change records over one or more first time intervals;
• periodically performing an increment adjustment comprising:
• adding an additional apply process to the set of active apply processes;
• determining a second throughput value based on a number of processed change records over one or more second time intervals;
• removing the additional apply process from the set of active apply processes if the second throughput value is not greater than a previous throughput value by at least an increment threshold, wherein the previous throughput value is based on the last determined first throughput value before the increment adjustment;
• periodically performing a decrement adjustment comprising:
• removing an apply process from the set of active apply processes;
• determining a third throughput value based on a number of processed change records over one or more third time intervals;
• replacing the removed apply process in the set of active apply processes if the third throughput value is not greater than the previous throughput value by at least a decrement threshold, wherein the previous throughput value is based on the last determined first throughput value before the decrement adjustment;
• wherein the method is performed by one or more computing devices.