Java 类org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob.State 实例源码

项目：hadoop 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：hadoop 文件：JobControl.java

/**
 * Add a new controlled job.
 * @param aJob the new controlled job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：aliyun-oss-hadoop-fs 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：aliyun-oss-hadoop-fs 文件：JobControl.java

/**
 * Add a new controlled job.
 * @param aJob the new controlled job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：big-c 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：big-c 文件：JobControl.java

/**
 * Add a new controlled job.
 * @param aJob the new controlled job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：hadoop-2.6.0-cdh5.4.3 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：JobControl.java

/**
 * Add a new controlled job.
 * @param aJob the new controlled job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：hadoop-2.6.0-cdh5.4.3 文件：JobControl.java

private Map<String, ControlledJob> getQueue(State state) {
  Map<String, ControlledJob> retv = null;
  if (state == State.WAITING) {
    retv = this.waitingJobs;
  } else if (state == State.READY) {
    retv = this.readyJobs;
  } else if (state == State.RUNNING) {
    retv = this.runningJobs;
  } else if (state == State.SUCCESS) {
    retv = this.successfulJobs;
  } else if (state == State.FAILED || state == State.DEPENDENT_FAILED) {
    retv = this.failedJobs;
  } 
  return retv;
}

项目：hadoop-2.6.0-cdh5.4.3 文件：JobControl.java

/**
 * Add a new job.
 * @param aJob the new job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  this.addToQueue(aJob);
  return id;    
}

项目：hadoop-plus 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：hadoop-plus 文件：JobControl.java

/**
 * Add a new controlled job.
 * @param aJob the new controlled job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：FlexMap 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：FlexMap 文件：JobControl.java

/**
 * Add a new controlled job.
 * @param aJob the new controlled job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：hops 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：hops 文件：JobControl.java

/**
 * Add a new controlled job.
 * @param aJob the new controlled job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：hadoop-TCP 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：hadoop-TCP 文件：JobControl.java

/**
 * Add a new controlled job.
 * @param aJob the new controlled job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：spork-streaming 文件：PigJobControl.java

private State checkState(ControlledJob j) {
  try {
    return (State)checkState.invoke(j);
  } catch (Exception e) {
    throw new RuntimeException(e);
  }
}

项目：spork-streaming 文件：PigJobControl.java

private State submit(ControlledJob j) {
  try {
    return (State)submit.invoke(j);
  } catch (Exception e) {
    throw new RuntimeException(e);
  }
}

项目：spork 文件：PigJobControl.java

private State checkState(ControlledJob j) {
  try {
    return (State)checkState.invoke(j);
  } catch (Exception e) {
    throw new RuntimeException(e);
  }
}

项目：spork 文件：PigJobControl.java

private State submit(ControlledJob j) {
  try {
    return (State)submit.invoke(j);
  } catch (Exception e) {
    throw new RuntimeException(e);
  }
}

项目：hadoop-on-lustre 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：hadoop-on-lustre 文件：JobControl.java

/**
 * Add a new job.
 * @param aJob the new job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：hardfs 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：hardfs 文件：JobControl.java

/**
 * Add a new controlled job.
 * @param aJob the new controlled job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：hadoop-on-lustre2 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：hadoop-on-lustre2 文件：JobControl.java

/**
 * Add a new controlled job.
 * @param aJob the new controlled job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：hanoi-hadoop-2.0.0-cdh 文件：JobControl.java

private Map<String, ControlledJob> getQueue(State state) {
  Map<String, ControlledJob> retv = null;
  if (state == State.WAITING) {
    retv = this.waitingJobs;
  } else if (state == State.READY) {
    retv = this.readyJobs;
  } else if (state == State.RUNNING) {
    retv = this.runningJobs;
  } else if (state == State.SUCCESS) {
    retv = this.successfulJobs;
  } else if (state == State.FAILED || state == State.DEPENDENT_FAILED) {
    retv = this.failedJobs;
  } 
  return retv;
}

项目：hanoi-hadoop-2.0.0-cdh 文件：JobControl.java

/**
 * Add a new job.
 * @param aJob the new job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  this.addToQueue(aJob);
  return id;    
}

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

private Map<String, ControlledJob> getQueue(State state) {
  Map<String, ControlledJob> retv = null;
  if (state == State.WAITING) {
    retv = this.waitingJobs;
  } else if (state == State.READY) {
    retv = this.readyJobs;
  } else if (state == State.RUNNING) {
    retv = this.runningJobs;
  } else if (state == State.SUCCESS) {
    retv = this.successfulJobs;
  } else if (state == State.FAILED || state == State.DEPENDENT_FAILED) {
    retv = this.failedJobs;
  } 
  return retv;
}

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

/**
 * Add a new job.
 * @param aJob the new job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  this.addToQueue(aJob);
  return id;    
}

项目：hortonworks-extension 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：hortonworks-extension 文件：JobControl.java

/**
 * Add a new job.
 * @param aJob the new job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：hortonworks-extension 文件：JobControl.java

synchronized private List<ControlledJob> getJobsIn(State state) {
  LinkedList<ControlledJob> l = new LinkedList<ControlledJob>();
  for(ControlledJob j: jobsInProgress) {
    if(j.getJobState() == state) {
      l.add(j);
    }
  }
  return l;
}

项目：hortonworks-extension 文件：JobControl.java

/**
 * Add a new job.
 * @param aJob the new job
 */
synchronized public String addJob(ControlledJob aJob) {
  String id = this.getNextJobID();
  aJob.setJobID(id);
  aJob.setJobState(State.WAITING);
  jobsInProgress.add(aJob);
  return id;    
}

项目：hadoop 文件：JobControl.java

/**
 * @return the jobs in the waiting state
 */
public List<ControlledJob> getWaitingJobList() {
  return getJobsIn(State.WAITING);
}

项目：hadoop 文件：JobControl.java

/**
 * @return the jobs in the running state
 */
public List<ControlledJob> getRunningJobList() {
  return getJobsIn(State.RUNNING);
}

项目：hadoop 文件：JobControl.java

/**
 * @return the jobs in the ready state
 */
public List<ControlledJob> getReadyJobsList() {
  return getJobsIn(State.READY);
}

项目：aliyun-oss-hadoop-fs 文件：JobControl.java

/**
 * @return the jobs in the waiting state
 */
public List<ControlledJob> getWaitingJobList() {
  return getJobsIn(State.WAITING);
}