public abstract class ApplicationMasterBase extends Object
JobManager
implementation in a Yarn container.
The only functions which have to be overwritten are the getJobManagerClass and getArchivistClass, which define the actors to be started.
Constructor and Description |
---|
ApplicationMasterBase() |
Modifier and Type | Method and Description |
---|---|
String |
CONF_FILE() |
Configuration |
createConfiguration(String curDir,
String dynamicPropertiesEncodedString) |
void |
generateConfigurationFile(String fileName,
String currDir,
String ownHostname,
int jobManagerPort,
int jobManagerWebPort,
int slots,
int taskManagerCount,
String dynamicPropertiesEncodedString) |
abstract Class<? extends MemoryArchivist> |
getArchivistClass() |
abstract Class<? extends JobManager> |
getJobManagerClass() |
static boolean |
hasStreamingMode(Map<String,String> env) |
org.slf4j.Logger |
log() |
String |
MAX_REGISTRATION_DURATION() |
String |
MODIFIED_CONF_FILE() |
void |
run(String[] args) |
void |
runAction() |
public org.slf4j.Logger log()
public String CONF_FILE()
public String MODIFIED_CONF_FILE()
public String MAX_REGISTRATION_DURATION()
public abstract Class<? extends JobManager> getJobManagerClass()
public abstract Class<? extends MemoryArchivist> getArchivistClass()
public void run(String[] args)
public void runAction()
public void generateConfigurationFile(String fileName, String currDir, String ownHostname, int jobManagerPort, int jobManagerWebPort, int slots, int taskManagerCount, String dynamicPropertiesEncodedString)
public Configuration createConfiguration(String curDir, String dynamicPropertiesEncodedString)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.