public abstract class AbstractAllocator extends LifecycleObjectSupport
Constructor and Description |
---|
AbstractAllocator() |
Modifier and Type | Method and Description |
---|---|
org.apache.hadoop.yarn.api.records.ApplicationAttemptId |
getApplicationAttemptId()
Gets the application attempt id.
|
org.apache.hadoop.conf.Configuration |
getConfiguration()
Gets the Yarn configuration.
|
java.util.Map<java.lang.String,java.lang.String> |
getEnvironment()
Gets the environment.
|
AppmasterRmOperations |
getRmTemplate()
Gets the rm template.
|
protected void |
onInit()
Subclasses may implement this for initialization logic.
|
void |
setApplicationAttemptId(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId)
Sets the application attempt id.
|
void |
setConfiguration(org.apache.hadoop.conf.Configuration configuration)
Sets the Yarn configuration.
|
void |
setEnvironment(java.util.Map<java.lang.String,java.lang.String> environment)
Sets the environment.
|
void |
setRmTemplate(AppmasterRmOperations rmTemplate)
Sets the rm template.
|
afterPropertiesSet, doStart, doStop, getBeanFactory, getPhase, getTaskExecutor, getTaskScheduler, getYarnEventPublisher, isAutoStartup, isRunning, setAutoStartup, setBeanFactory, setPhase, setTaskExecutor, setTaskScheduler, setYarnEventPublisher, start, stop, stop
protected void onInit() throws java.lang.Exception
LifecycleObjectSupport
InitializingBean
phase. Implementor should
always call super method not to break initialization chain.onInit
in class LifecycleObjectSupport
java.lang.Exception
- exceptionpublic org.apache.hadoop.yarn.api.records.ApplicationAttemptId getApplicationAttemptId()
public void setApplicationAttemptId(org.apache.hadoop.yarn.api.records.ApplicationAttemptId applicationAttemptId)
applicationAttemptId
- the new application attempt idpublic org.apache.hadoop.conf.Configuration getConfiguration()
public void setConfiguration(org.apache.hadoop.conf.Configuration configuration)
configuration
- the new Yarn configurationpublic java.util.Map<java.lang.String,java.lang.String> getEnvironment()
public void setEnvironment(java.util.Map<java.lang.String,java.lang.String> environment)
environment
- the environmentpublic void setRmTemplate(AppmasterRmOperations rmTemplate)
rmTemplate
- the new rm templatepublic AppmasterRmOperations getRmTemplate()