Package org.apache.hadoop.mapreduce
Class TypeConverter
java.lang.Object
org.apache.hadoop.mapreduce.TypeConverter
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionstatic List<org.apache.hadoop.mapreduce.TaskReport>fromYarn(List<TaskReport> taskReports) static org.apache.hadoop.mapreduce.Countersstatic org.apache.hadoop.mapred.JobIDstatic org.apache.hadoop.mapreduce.JobStatusstatic intstatic org.apache.hadoop.mapred.TaskCompletionEventfromYarn(TaskAttemptCompletionEvent newEvent) static org.apache.hadoop.mapred.TaskCompletionEvent[]fromYarn(TaskAttemptCompletionEvent[] newEvents) static org.apache.hadoop.mapred.TaskCompletionEvent.StatusfromYarn(TaskAttemptCompletionEventStatus newStatus) static org.apache.hadoop.mapred.TaskAttemptIDstatic org.apache.hadoop.mapred.TaskIDstatic org.apache.hadoop.mapreduce.TaskReportfromYarn(TaskReport report) static org.apache.hadoop.mapred.TIPStatusstatic org.apache.hadoop.mapreduce.TaskTypestatic org.apache.hadoop.mapreduce.JobIDfromYarn(org.apache.hadoop.yarn.api.records.ApplicationId appID) static org.apache.hadoop.mapreduce.JobStatusstatic org.apache.hadoop.mapreduce.TaskTrackerInfofromYarn(org.apache.hadoop.yarn.api.records.NodeReport node) static org.apache.hadoop.mapreduce.QueueInfofromYarn(org.apache.hadoop.yarn.api.records.QueueInfo queueInfo, org.apache.hadoop.conf.Configuration conf) static org.apache.hadoop.mapreduce.QueueStatefromYarn(org.apache.hadoop.yarn.api.records.QueueState state) static org.apache.hadoop.mapreduce.JobStatus.StatefromYarn(org.apache.hadoop.yarn.api.records.YarnApplicationState yarnApplicationState, org.apache.hadoop.yarn.api.records.FinalApplicationStatus finalApplicationStatus) static org.apache.hadoop.mapreduce.JobPriorityfromYarnApplicationPriority(int priority) static org.apache.hadoop.mapreduce.JobStatus[]fromYarnApps(List<org.apache.hadoop.yarn.api.records.ApplicationReport> applications, org.apache.hadoop.conf.Configuration conf) static org.apache.hadoop.mapreduce.TaskTrackerInfo[]fromYarnNodes(List<org.apache.hadoop.yarn.api.records.NodeReport> nodes) static org.apache.hadoop.mapreduce.QueueInfo[]fromYarnQueueInfo(List<org.apache.hadoop.yarn.api.records.QueueInfo> queues, org.apache.hadoop.conf.Configuration conf) static org.apache.hadoop.mapreduce.QueueAclsInfo[]fromYarnQueueUserAclsInfo(List<org.apache.hadoop.yarn.api.records.QueueUserACLInfo> userAcls) static CounterstoYarn(org.apache.hadoop.mapred.Counters counters) static TaskAttemptIdtoYarn(org.apache.hadoop.mapred.TaskAttemptID id) static PhasetoYarn(org.apache.hadoop.mapred.TaskStatus.Phase phase) static TaskAttemptStatetoYarn(org.apache.hadoop.mapred.TaskStatus.State state) static CounterstoYarn(org.apache.hadoop.mapreduce.Counters counters) static JobIdtoYarn(org.apache.hadoop.mapreduce.JobID id) static TaskAttemptIdtoYarn(org.apache.hadoop.mapreduce.TaskAttemptID id) static TaskIdtoYarn(org.apache.hadoop.mapreduce.TaskID id) static TaskTypetoYarn(org.apache.hadoop.mapreduce.TaskType taskType) static inttoYarnApplicationPriority(String priority)
-
Constructor Details
-
TypeConverter
public TypeConverter()
-
-
Method Details
-
fromYarn
-
fromYarn
public static org.apache.hadoop.mapreduce.JobID fromYarn(org.apache.hadoop.yarn.api.records.ApplicationId appID) -
toYarn
-
toYarnApplicationPriority
-
fromYarn
-
toYarn
-
fromYarn
-
toYarn
-
toYarn
-
toYarn
-
fromYarn
public static org.apache.hadoop.mapred.TaskCompletionEvent[] fromYarn(TaskAttemptCompletionEvent[] newEvents) -
fromYarn
public static org.apache.hadoop.mapred.TaskCompletionEvent fromYarn(TaskAttemptCompletionEvent newEvent) -
fromYarn
public static org.apache.hadoop.mapred.TaskCompletionEvent.Status fromYarn(TaskAttemptCompletionEventStatus newStatus) -
fromYarn
-
toYarn
-
toYarn
-
fromYarn
-
toYarn
-
toYarn
-
fromYarn
-
fromYarnApplicationPriority
public static org.apache.hadoop.mapreduce.JobPriority fromYarnApplicationPriority(int priority) -
fromYarn
public static org.apache.hadoop.mapreduce.QueueState fromYarn(org.apache.hadoop.yarn.api.records.QueueState state) -
fromYarn
-
fromYarn
-
fromYarn
-
fromYarn
-
fromYarn
public static org.apache.hadoop.mapreduce.JobStatus.State fromYarn(org.apache.hadoop.yarn.api.records.YarnApplicationState yarnApplicationState, org.apache.hadoop.yarn.api.records.FinalApplicationStatus finalApplicationStatus) -
fromYarn
public static org.apache.hadoop.mapreduce.TaskTrackerInfo fromYarn(org.apache.hadoop.yarn.api.records.NodeReport node) -
fromYarnNodes
public static org.apache.hadoop.mapreduce.TaskTrackerInfo[] fromYarnNodes(List<org.apache.hadoop.yarn.api.records.NodeReport> nodes) -
fromYarn
public static org.apache.hadoop.mapreduce.JobStatus fromYarn(org.apache.hadoop.yarn.api.records.ApplicationReport application, String jobFile) -
fromYarnApps
public static org.apache.hadoop.mapreduce.JobStatus[] fromYarnApps(List<org.apache.hadoop.yarn.api.records.ApplicationReport> applications, org.apache.hadoop.conf.Configuration conf) -
fromYarn
public static org.apache.hadoop.mapreduce.QueueInfo fromYarn(org.apache.hadoop.yarn.api.records.QueueInfo queueInfo, org.apache.hadoop.conf.Configuration conf) -
fromYarnQueueInfo
public static org.apache.hadoop.mapreduce.QueueInfo[] fromYarnQueueInfo(List<org.apache.hadoop.yarn.api.records.QueueInfo> queues, org.apache.hadoop.conf.Configuration conf) -
fromYarnQueueUserAclsInfo
public static org.apache.hadoop.mapreduce.QueueAclsInfo[] fromYarnQueueUserAclsInfo(List<org.apache.hadoop.yarn.api.records.QueueUserACLInfo> userAcls)
-