Spring for Apache Hadoop

org.springframework.yarn.container
Class DefaultYarnContainer

java.lang.Object
  extended by org.springframework.yarn.container.AbstractYarnContainer
      extended by org.springframework.yarn.container.DefaultYarnContainer
All Implemented Interfaces:
org.springframework.beans.factory.Aware, org.springframework.beans.factory.BeanFactoryAware, LongRunningYarnContainer, YarnContainer, YarnContainerRuntime

public class DefaultYarnContainer
extends AbstractYarnContainer
implements org.springframework.beans.factory.BeanFactoryAware

Default implementation of a YarnContainer.

Author:
Janne Valkealahti

Constructor Summary
DefaultYarnContainer()
           
 
Method Summary
 boolean isWaitCompleteState()
          Indication for possible handler using this bean whether it should wait COMPLETED state.
protected  void runInternal()
          Internal method to handle the actual AbstractYarnContainer.run() method.
 void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
           
 
Methods inherited from class org.springframework.yarn.container.AbstractYarnContainer
addContainerStateListener, getConfiguration, getEnvironment, getEnvironment, getParameters, notifyCompleted, notifyCompleted, notifyContainerState, run, setConfiguration, setEnvironment, setParameters
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

DefaultYarnContainer

public DefaultYarnContainer()
Method Detail

runInternal

protected void runInternal()
Description copied from class: AbstractYarnContainer
Internal method to handle the actual AbstractYarnContainer.run() method.

Specified by:
runInternal in class AbstractYarnContainer

setBeanFactory

public void setBeanFactory(org.springframework.beans.factory.BeanFactory beanFactory)
                    throws org.springframework.beans.BeansException
Specified by:
setBeanFactory in interface org.springframework.beans.factory.BeanFactoryAware
Throws:
org.springframework.beans.BeansException

isWaitCompleteState

public boolean isWaitCompleteState()
Description copied from interface: LongRunningYarnContainer
Indication for possible handler using this bean whether it should wait COMPLETED state.

Specified by:
isWaitCompleteState in interface LongRunningYarnContainer
Overrides:
isWaitCompleteState in class AbstractYarnContainer
Returns:
True if complete state should be wait
See Also:
LongRunningYarnContainer.addContainerStateListener(ContainerStateListener)

Spring for Apache Hadoop