I am using Mapreduce v2. On Aug 25, 2016 8:18 PM, "xeon Mailinglist" <xeonmailingl...@gmail.com> wrote:
> I am trying to implement a mechanism in MapReduce v2 that allows to > suspend and resume a job. I must suspend a job when all the mappers finish, > and resume the job from that point after some time. I do this, because I > want to verify the integrity of the map output before executing the > reducers. > > I am looking for the class that tells when the Reduce tasks should start. > Does anyone know where is this? >
