public abstract class AbstractYarnContainer extends Object implements LongRunningYarnContainer, YarnContainerRuntime
YarnContainer providing
some common functionality like environment properties,
command line parameters and handling of the run().| Constructor and Description |
|---|
AbstractYarnContainer() |
| Modifier and Type | Method and Description |
|---|---|
void |
addContainerStateListener(ContainerStateListener listener)
Adds the container state listener.
|
Configuration |
getConfiguration()
Gets the Yarn configuration.
|
Map<String,String> |
getEnvironment()
Gets the environment.
|
String |
getEnvironment(String key)
Gets the environment variable.
|
Properties |
getParameters()
Gets the parameters.
|
boolean |
isWaitCompleteState()
Indication for possible handler using this bean whether
it should wait
COMPLETED
state. |
protected void |
notifyCompleted()
Notify completed state to container state listeners.
|
protected void |
notifyCompleted(int exit)
Notify completed state to container state listeners.
|
protected void |
notifyContainerState(ContainerStateListener.ContainerState state,
Object exit)
Notify state to container state listeners.
|
void |
run()
This method is called when something is ran
in a container.
|
protected abstract void |
runInternal()
Internal method to handle the actual
run() method. |
void |
setConfiguration(Configuration configuration)
Sets the Yarn configuration.
|
void |
setEnvironment(Map<String,String> environment)
Sets the environment variables.
|
void |
setParameters(Properties parameters)
Sets the parameters.
|
public final void run()
YarnContainerrun in interface YarnContainerpublic void setEnvironment(Map<String,String> environment)
YarnContainersetEnvironment in interface YarnContainerenvironment - the environment variablespublic void setParameters(Properties parameters)
YarnContainersetParameters in interface YarnContainerparameters - the parameterspublic Configuration getConfiguration()
public void setConfiguration(Configuration configuration)
configuration - the new Yarn configurationpublic String getEnvironment(String key)
key - the keynull if key doesn't existpublic Map<String,String> getEnvironment()
getEnvironment in interface YarnContainerRuntimepublic Properties getParameters()
getParameters in interface YarnContainerRuntimepublic void addContainerStateListener(ContainerStateListener listener)
LongRunningYarnContaineraddContainerStateListener in interface LongRunningYarnContainerlistener - the ContainerStateListenerpublic boolean isWaitCompleteState()
LongRunningYarnContainerCOMPLETED
state.isWaitCompleteState in interface LongRunningYarnContainerLongRunningYarnContainer.addContainerStateListener(ContainerStateListener)protected void notifyCompleted()
protected void notifyCompleted(int exit)
exit - the exitprotected void notifyContainerState(ContainerStateListener.ContainerState state, Object exit)
state - the stateexit - the exitprotected abstract void runInternal()
run() method.