public LocalJobRunner(JobConf conf) throws IOException 
{
    this.fs = FileSystem.get(conf);
    this.conf = conf;
    myMetrics = new JobTrackerMetrics(new JobConf(conf));
}

 public ClusterStatus getClusterStatus() 
{
    return new ClusterStatus(1, map_tasks, reduce_tasks, 1);
}

 public String getFilesystemName() throws IOException 
{
    return fs.getName();
}

 public Counters getJobCounters(String id) 
{
    Job job = jobs.get(id);
    return job.currentCounters;
}

 public JobProfile getJobProfile(String id) 
{
    Job job = jobs.get(id);
    if(job != null)
      return job.getProfile();
    else 
      return null;
}

 public JobStatus getJobStatus(String id) 
{
    Job job = jobs.get(id);
    if(job != null)
      return job.status;
    else 
      return null;
}

 public TaskReport[] getMapTaskReports(String id) 
{
    return new TaskReport[0];
}

 public String getNewJobId() 
{
     
    return "job_local_" + Integer.toString(++jobid);
}

 public long getProtocolVersion(String protocol,
    long clientVersion) 
{
        
    return JobSubmissionProtocol.versionID;
}

 public TaskReport[] getReduceTaskReports(String id) 
{
    return new TaskReport[0];
}

 public TaskCompletionEvent[] getTaskCompletionEvents(String jobid,
    int fromEventId,
    int maxEvents) throws IOException 
{
    return TaskCompletionEvent.EMPTY_ARRAY;
}

 public JobStatus[] jobsToComplete() 
{
return null;
}

 public  void killJob(String id) 
{
    jobs.get(id).stop();
}

 public JobStatus submitJob(String jobid) throws IOException 
{
    return new Job(jobid, this.conf).status;
}