Java 类org.apache.hadoop.mapred.FakeJobs 实例源码

项目：hadoop-EAR 文件：TestSimulatorJobTracker.java

public void submitNewJob() throws IOException, InterruptedException {
  org.apache.hadoop.mapreduce.JobID jobId = jobTracker.getNewJobID();
  LOG.info("Obtained from Jobtracker jobid = " + jobId);
  FakeJobs job = new FakeJobs("job1", 0, numMaps, numReduces);

  SimulatorJobCache.put(org.apache.hadoop.mapred.JobID.downgrade(jobId), job);
  jobTracker.submitJob(jobId);
}

项目：RDFS 文件：TestSimulatorJobTracker.java

public void submitNewJob() throws IOException, InterruptedException {
  org.apache.hadoop.mapreduce.JobID jobId = jobTracker.getNewJobID();
  LOG.info("Obtained from Jobtracker jobid = " + jobId);
  FakeJobs job = new FakeJobs("job1", 0, numMaps, numReduces);

  SimulatorJobCache.put(org.apache.hadoop.mapred.JobID.downgrade(jobId), job);
  jobTracker.submitJob(jobId);
}

项目：mapreduce-fork 文件：TestSimulatorJobTracker.java

public void submitNewJob() throws IOException, InterruptedException {
  org.apache.hadoop.mapreduce.JobID jobId = jobTracker.getNewJobID();
  LOG.info("Obtained from Jobtracker jobid = " + jobId);
  FakeJobs job = new FakeJobs("job1", 0, numMaps, numReduces);

  SimulatorJobCache.put(org.apache.hadoop.mapred.JobID.downgrade(jobId), job);
  jobTracker.submitJob(jobId, "dummy-path", null);
}