private Collection<HadoopTaskInfo> mapperTasks(Iterable<HadoopInputSplit> mappers,HadoopJobMetadata meta){
  UUID locNodeId=ctx.localNodeId();
  HadoopJobId jobId=meta.jobId();
  JobLocalState state=activeJobs.get(jobId);
  Collection<HadoopTaskInfo> tasks=null;
  if (mappers != null) {
    if (state == null)     state=initState(jobId);
    for (    HadoopInputSplit split : mappers) {
      if (state.addMapper(split)) {
        if (log.isDebugEnabled())         log.debug("Submitting MAP task for execution [locNodeId=" + locNodeId + ", split="+ split+ ']');
        HadoopTaskInfo taskInfo=new HadoopTaskInfo(MAP,jobId,meta.taskNumber(split),0,split);
        if (tasks == null)         tasks=new ArrayList<>();
        tasks.add(taskInfo);
      }
    }
  }
  return tasks;
}

private Collection < HadoopTaskInfo > mapperTasks ( Iterable < HadoopInputSplit > mappers , HadoopJobMetadata meta ) { UUID locNodeId = ctx . localNodeId ( ) ; HadoopJobId jobId = meta . jobId ( ) ; JobLocalState state = activeJobs . get ( jobId ) ; Collection < HadoopTaskInfo > tasks = null ; if ( mappers != null ) { if ( state == null ) state = initState ( jobId ) ; for ( HadoopInputSplit split : mappers ) { if ( state . addMapper ( split ) ) { if ( log . isDebugEnabled ( ) ) log . debug ( "Submitting MAP task for execution [locNodeId=" + locNodeId + ", split=" + split + ']' ) ; HadoopTaskInfo taskInfo = new HadoopTaskInfo ( MAP , jobId , meta . taskNumber ( split ) , 0 , split ) ; if ( tasks == null ) tasks = new ArrayList < > ( ) ; tasks . add ( taskInfo ) ; } } } return tasks ; }
creates mapper tasks based on job information .
