Major Description
We should extend the BSPJob to let the user set the checkpoint intervals.
job.setCheckpointInterval(5);
This method should put the parameter into the configuration of the job with a meaningful key, e.G. "bsp.checkpoint.interval".
In the BSPPeerImpl we should check if this interval has been reached and make the checkpointing accordingly.
Checkpointing gets called in BSPPeerImpl#sync(), there is already a condition which checks if checkpointing is enabled.
Plus points:
If you can provide an additional method in BSPJob that let's the user enable or disable checkpointing. Hint: Configuration key is: "bsp.checkpoint.enabled".