public void processIncomingAccumulators ( JobID jobID , Map < String , Accumulator < ? , ? > > newAccumulators ) { synchronized ( this . jobAccumulators ) { // System.out.println("JobManager: Received accumulator result for job " // + jobID.toString()); // System.out.println(AccumulatorHelper.getAccumulatorsFormated(newAccumulators)); JobAccumulators jobAccumulators = this . jobAccumulators . get ( jobID ) ; if ( jobAccumulators == null ) { jobAccumulators = new JobAccumulators ( ) ; this . jobAccumulators . put ( jobID , jobAccumulators ) ; cleanup ( jobID ) ; } jobAccumulators . processNew ( newAccumulators ) ; } }
Merges the new accumulators with the existing accumulators collected for the job .