1. 包列表
  2. 类列表
  3. org.apache.hadoop.mapreduce.jobhistory.TaskAttemptFinished

Java 类org.apache.hadoop.mapreduce.jobhistory.TaskAttemptFinished 实例源码

项目：hadoop    文件：JobBuilder.java    
private void processTaskAttemptFinishedEvent(TaskAttemptFinishedEvent event) {
  ParsedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getAttemptId().toString());
  if (attempt == null) {
    return;
  }
  attempt.setResult(getPre21Value(event.getTaskStatus()));
  ParsedHost pHost = getAndRecordParsedHost(event.getRackName(), event.getHostname());
  if (pHost != null) {
    attempt.setLocation(pHost.makeLoggedLocation());
  }
  attempt.setFinishTime(event.getFinishTime());
  attempt
      .incorporateCounters(((TaskAttemptFinished) event.getDatum()).counters);
}
项目：aliyun-oss-hadoop-fs    文件：JobBuilder.java    
private void processTaskAttemptFinishedEvent(TaskAttemptFinishedEvent event) {
  ParsedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getAttemptId().toString());
  if (attempt == null) {
    return;
  }
  attempt.setResult(getPre21Value(event.getTaskStatus()));
  ParsedHost pHost = getAndRecordParsedHost(event.getRackName(), event.getHostname());
  if (pHost != null) {
    attempt.setLocation(pHost.makeLoggedLocation());
  }
  attempt.setFinishTime(event.getFinishTime());
  attempt
      .incorporateCounters(((TaskAttemptFinished) event.getDatum()).counters);
}
项目：big-c    文件：JobBuilder.java    
private void processTaskAttemptFinishedEvent(TaskAttemptFinishedEvent event) {
  ParsedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getAttemptId().toString());
  if (attempt == null) {
    return;
  }
  attempt.setResult(getPre21Value(event.getTaskStatus()));
  ParsedHost pHost = getAndRecordParsedHost(event.getRackName(), event.getHostname());
  if (pHost != null) {
    attempt.setLocation(pHost.makeLoggedLocation());
  }
  attempt.setFinishTime(event.getFinishTime());
  attempt
      .incorporateCounters(((TaskAttemptFinished) event.getDatum()).counters);
}
项目：hadoop-2.6.0-cdh5.4.3    文件：JobBuilder.java    
private void processTaskAttemptFinishedEvent(TaskAttemptFinishedEvent event) {
  ParsedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getAttemptId().toString());
  if (attempt == null) {
    return;
  }
  attempt.setResult(getPre21Value(event.getTaskStatus()));
  ParsedHost pHost = getAndRecordParsedHost(event.getRackName(), event.getHostname());
  if (pHost != null) {
    attempt.setLocation(pHost.makeLoggedLocation());
  }
  attempt.setFinishTime(event.getFinishTime());
  attempt
      .incorporateCounters(((TaskAttemptFinished) event.getDatum()).counters);
}
项目：hadoop-plus    文件：JobBuilder.java    
private void processTaskAttemptFinishedEvent(TaskAttemptFinishedEvent event) {
  ParsedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getAttemptId().toString());
  if (attempt == null) {
    return;
  }
  attempt.setResult(getPre21Value(event.getTaskStatus()));
  ParsedHost pHost = getAndRecordParsedHost(event.getRackName(), event.getHostname());
  if (pHost != null) {
    attempt.setLocation(pHost.makeLoggedLocation());
  }
  attempt.setFinishTime(event.getFinishTime());
  attempt
      .incorporateCounters(((TaskAttemptFinished) event.getDatum()).counters);
}
项目：hops    文件：JobBuilder.java    
private void processTaskAttemptFinishedEvent(TaskAttemptFinishedEvent event) {
  ParsedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getAttemptId().toString());
  if (attempt == null) {
    return;
  }
  attempt.setResult(getPre21Value(event.getTaskStatus()));
  ParsedHost pHost = getAndRecordParsedHost(event.getRackName(), event.getHostname());
  if (pHost != null) {
    attempt.setLocation(pHost.makeLoggedLocation());
  }
  attempt.setFinishTime(event.getFinishTime());
  attempt
      .incorporateCounters(((TaskAttemptFinished) event.getDatum()).counters);
}
项目：hadoop-TCP    文件：JobBuilder.java    
private void processTaskAttemptFinishedEvent(TaskAttemptFinishedEvent event) {
  ParsedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getAttemptId().toString());
  if (attempt == null) {
    return;
  }
  attempt.setResult(getPre21Value(event.getTaskStatus()));
  ParsedHost pHost = getAndRecordParsedHost(event.getRackName(), event.getHostname());
  if (pHost != null) {
    attempt.setLocation(pHost.makeLoggedLocation());
  }
  attempt.setFinishTime(event.getFinishTime());
  attempt
      .incorporateCounters(((TaskAttemptFinished) event.getDatum()).counters);
}
项目：hardfs    文件：JobBuilder.java    
private void processTaskAttemptFinishedEvent(TaskAttemptFinishedEvent event) {
  ParsedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getAttemptId().toString());
  if (attempt == null) {
    return;
  }
  attempt.setResult(getPre21Value(event.getTaskStatus()));
  ParsedHost pHost = getAndRecordParsedHost(event.getRackName(), event.getHostname());
  if (pHost != null) {
    attempt.setLocation(pHost.makeLoggedLocation());
  }
  attempt.setFinishTime(event.getFinishTime());
  attempt
      .incorporateCounters(((TaskAttemptFinished) event.getDatum()).counters);
}
项目：hadoop-on-lustre2    文件：JobBuilder.java    
private void processTaskAttemptFinishedEvent(TaskAttemptFinishedEvent event) {
  ParsedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getAttemptId().toString());
  if (attempt == null) {
    return;
  }
  attempt.setResult(getPre21Value(event.getTaskStatus()));
  ParsedHost pHost = getAndRecordParsedHost(event.getRackName(), event.getHostname());
  if (pHost != null) {
    attempt.setLocation(pHost.makeLoggedLocation());
  }
  attempt.setFinishTime(event.getFinishTime());
  attempt
      .incorporateCounters(((TaskAttemptFinished) event.getDatum()).counters);
}
项目：mapreduce-fork    文件：JobBuilder.java    
private void processTaskAttemptFinishedEvent(TaskAttemptFinishedEvent event) {
  LoggedTaskAttempt attempt =
      getOrMakeTaskAttempt(event.getTaskType(), event.getTaskId().toString(),
          event.getAttemptId().toString());
  if (attempt == null) {
    return;
  }
  attempt.setResult(getPre21Value(event.getTaskStatus()));
  attempt.setLocation(getAndRecordParsedHost(event.getHostname())
      .makeLoggedLocation());
  attempt.setFinishTime(event.getFinishTime());
  attempt
      .incorporateCounters(((TaskAttemptFinished) event.getDatum()).counters);
}