org.apache.hadoop.mapred

Class MapCollectiveRunner

java.lang.Object

YARNRunner

org.apache.hadoop.mapred.MapCollectiveRunner

public class MapCollectiveRunner
extends YARNRunner

This class is modified from YARNRunner for submitting map-collective jobs. In createApplicationSubmissionContext, launch MapCollectiveAppMaster

Constructor Summary

Constructors

Constructor and Description
MapCollectiveRunner(Configuration conf)

Method Summary

Modifier and Type	Method and Description
ApplicationSubmissionContext	createApplicationSubmissionContext(Configuration jobConf, java.lang.String jobSubmitDir, Credentials ts)

Methods inherited from class java.lang.Object

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

Constructor Detail

MapCollectiveRunner

public MapCollectiveRunner(Configuration conf)

Method Detail

createApplicationSubmissionContext

public ApplicationSubmissionContext createApplicationSubmissionContext(Configuration jobConf,
                                                                       java.lang.String jobSubmitDir,
                                                                       Credentials ts)
                                                                throws java.io.IOException

Throws:

java.io.IOException