Package org.apache.hadoop.mapreduce.v2.util

Class MRBuilderUtils

java.lang.Object

org.apache.hadoop.mapreduce.v2.util.MRBuilderUtils

public class MRBuilderUtils
extends Object

Constructor Summary

Constructors

Constructor	Description
MRBuilderUtils()

Method Summary

Modifier and Type	Method	Description
static AMInfo	newAMInfo(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId, long startTime, org.apache.hadoop.yarn.api.records.ContainerId containerId, String nmHost, int nmPort, int nmHttpPort)
static JobId	newJobId(long clusterTs, int appIdInt, int id)
static JobId	newJobId(org.apache.hadoop.yarn.api.records.ApplicationId appId, int id)
static JobReport	newJobReport(JobId jobId, String jobName, String userName, JobState state, long submitTime, long startTime, long finishTime, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, String jobFile, List<AMInfo> amInfos, boolean isUber, String diagnostics)
static JobReport	newJobReport(JobId jobId, String jobName, String userName, JobState state, long submitTime, long startTime, long finishTime, float setupProgress, float mapProgress, float reduceProgress, float cleanupProgress, String jobFile, List<AMInfo> amInfos, boolean isUber, String diagnostics, org.apache.hadoop.yarn.api.records.Priority priority)
static TaskAttemptId	newTaskAttemptId(TaskId taskId, int attemptId)
static TaskId	newTaskId(JobId jobId, int id, TaskType taskType)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

MRBuilderUtils

public MRBuilderUtils()

Method Details

newJobId

public static JobId newJobId(org.apache.hadoop.yarn.api.records.ApplicationId appId,
 int id)

newJobId

public static JobId newJobId(long clusterTs,
 int appIdInt,
 int id)

newTaskId

public static TaskId newTaskId(JobId jobId,
 int id,
 TaskType taskType)

newTaskAttemptId

public static TaskAttemptId newTaskAttemptId(TaskId taskId,
 int attemptId)

newJobReport

public static JobReport newJobReport(JobId jobId,
 String jobName,
 String userName,
 JobState state,
 long submitTime,
 long startTime,
 long finishTime,
 float setupProgress,
 float mapProgress,
 float reduceProgress,
 float cleanupProgress,
 String jobFile,
 List<AMInfo> amInfos,
 boolean isUber,
 String diagnostics)

newJobReport

public static JobReport newJobReport(JobId jobId,
 String jobName,
 String userName,
 JobState state,
 long submitTime,
 long startTime,
 long finishTime,
 float setupProgress,
 float mapProgress,
 float reduceProgress,
 float cleanupProgress,
 String jobFile,
 List<AMInfo> amInfos,
 boolean isUber,
 String diagnostics,
 org.apache.hadoop.yarn.api.records.Priority priority)

newAMInfo

public static AMInfo newAMInfo(org.apache.hadoop.yarn.api.records.ApplicationAttemptId appAttemptId,
 long startTime,
 org.apache.hadoop.yarn.api.records.ContainerId containerId,
 String nmHost,
 int nmPort,
 int nmHttpPort)