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

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

下面列出了org.apache.hadoop.mapreduce.lib.jobcontrol.ControlledJob.State 类实例代码,或者点击链接到github查看源代码,也可以在右侧发表评论。

源代码1 项目: 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;
}
 
源代码2 项目: 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;	
}
 
源代码3 项目: 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;
}
 
源代码4 项目: 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;	
}
 
源代码5 项目: spork   文件: PigJobControl.java
private State checkState(ControlledJob j) {
  try {
    return (State)checkState.invoke(j);
  } catch (Exception e) {
    throw new RuntimeException(e);
  }
}
 
源代码6 项目: spork   文件: PigJobControl.java
private State submit(ControlledJob j) {
  try {
    return (State)submit.invoke(j);
  } catch (Exception e) {
    throw new RuntimeException(e);
  }
}
 
源代码7 项目: hadoop   文件: JobControl.java
/**
 * @return the jobs in the waiting state
 */
public List<ControlledJob> getWaitingJobList() {
  return getJobsIn(State.WAITING);
}
 
源代码8 项目: hadoop   文件: JobControl.java
/**
 * @return the jobs in the running state
 */
public List<ControlledJob> getRunningJobList() {
  return getJobsIn(State.RUNNING);
}
 
源代码9 项目: hadoop   文件: JobControl.java
/**
 * @return the jobs in the ready state
 */
public List<ControlledJob> getReadyJobsList() {
  return getJobsIn(State.READY);
}
 
源代码10 项目: big-c   文件: JobControl.java
/**
 * @return the jobs in the waiting state
 */
public List<ControlledJob> getWaitingJobList() {
  return getJobsIn(State.WAITING);
}
 
源代码11 项目: big-c   文件: JobControl.java
/**
 * @return the jobs in the running state
 */
public List<ControlledJob> getRunningJobList() {
  return getJobsIn(State.RUNNING);
}
 
源代码12 项目: big-c   文件: JobControl.java
/**
 * @return the jobs in the ready state
 */
public List<ControlledJob> getReadyJobsList() {
  return getJobsIn(State.READY);
}
 
源代码评论
动弹
沙发等你来抢
 类方法
 同包方法