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

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

/**
 * Called when a job is completed. Insert a {@link JobCompleteEvent} into the
 * {@link SimulatorEventQueue}. This event will be picked up by
 * {@link SimulatorJobClient}, which will in turn decide whether the
 * simulation is done.
 * @param jobStatus final status of a job, SUCCEEDED or FAILED
 * @param timestamp time stamp when the job is completed
 */
void markCompletedJob(JobStatus jobStatus, long timestamp) {
  queue.add(new JobCompleteEvent(jc, timestamp, jobStatus, this));
}

项目：RDFS 文件：SimulatorEngine.java

/**
 * Called when a job is completed. Insert a {@link JobCompleteEvent} into the
 * {@link SimulatorEventQueue}. This event will be picked up by
 * {@link SimulatorJobClient}, which will in turn decide whether the
 * simulation is done.
 * @param jobStatus final status of a job, SUCCEEDED or FAILED
 * @param timestamp time stamp when the job is completed
 */
void markCompletedJob(JobStatus jobStatus, long timestamp) {
  queue.add(new JobCompleteEvent(jc, timestamp, jobStatus, this));
}

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

/**
 * Called when a job is completed. Insert a {@link JobCompleteEvent} into the
 * {@link SimulatorEventQueue}. This event will be picked up by
 * {@link SimulatorJobClient}, which will in turn decide whether the
 * simulation is done.
 * @param jobStatus final status of a job, SUCCEEDED or FAILED
 * @param timestamp time stamp when the job is completed
 */
void markCompletedJob(JobStatus jobStatus, long timestamp) {
  queue.add(new JobCompleteEvent(jc, timestamp, jobStatus, this));
}