org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptCompletionEvent#getMapOutputServerAddress ( )源码实例Demo

下面列出了org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptCompletionEvent#getMapOutputServerAddress ( ) 实例代码，或者点击链接到github查看源代码，也可以在右侧发表评论。

源代码1 项目： hadoop 文件： TypeConverter.java

public static TaskCompletionEvent fromYarn(
    TaskAttemptCompletionEvent newEvent) {
  return new TaskCompletionEvent(newEvent.getEventId(),
            fromYarn(newEvent.getAttemptId()), newEvent.getAttemptId().getId(),
            newEvent.getAttemptId().getTaskId().getTaskType().equals(TaskType.MAP),
            fromYarn(newEvent.getStatus()),
            newEvent.getMapOutputServerAddress());
}

源代码2 项目： big-c 文件： TypeConverter.java

public static TaskCompletionEvent fromYarn(
    TaskAttemptCompletionEvent newEvent) {
  return new TaskCompletionEvent(newEvent.getEventId(),
            fromYarn(newEvent.getAttemptId()), newEvent.getAttemptId().getId(),
            newEvent.getAttemptId().getTaskId().getTaskType().equals(TaskType.MAP),
            fromYarn(newEvent.getStatus()),
            newEvent.getMapOutputServerAddress());
}

方法所在类

org.apache.hadoop.mapreduce.v2.api.records.TaskAttemptCompletionEvent