Package org.apache.hadoop.yarn.service.provider

Class AbstractProviderService

java.lang.Object

org.apache.hadoop.yarn.service.provider.AbstractProviderService

All Implemented Interfaces:

YarnServiceConstants, ProviderService

Direct Known Subclasses:

DefaultProviderService, DockerProviderService, TarballProviderService

public abstract class AbstractProviderService
extends Object
implements ProviderService, YarnServiceConstants

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.hadoop.yarn.service.provider.ProviderService

ProviderService.ResolvedLaunchParams

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.slf4j.Logger	log

Fields inherited from interface org.apache.hadoop.yarn.service.provider.ProviderService

FAILED_LAUNCH_PARAMS

Fields inherited from interface org.apache.hadoop.yarn.service.conf.YarnServiceConstants

APP_CONF_DIR, APP_LIB_DIR, APP_RESOURCES_DIR, APP_TYPE, CONTAINER_STATE_REPORT_AS_SERVICE_STATE, CONTENT, DEPENDENCY_DIR, DEPENDENCY_DIR_PERMISSIONS, DEPENDENCY_LOCALIZED_DIR_LINK, DEPENDENCY_TAR_GZ_FILE_EXT, DEPENDENCY_TAR_GZ_FILE_NAME, ERR_FILE, HADOOP_USER_NAME, KEYTAB_DIR, KEYTAB_LOCATION, OUT_FILE, PRINCIPAL, PROPERTY_LIB_DIR, RESOURCE_DIR, SERVICE_BASE_DIRECTORY, SERVICE_CORE_JAR, SERVICES_DIRECTORY, SERVICES_PUBLIC_DIRECTORY, STDERR_AM, STDOUT_AM, SUBMITTED_CONF_DIR, SYSPROP_LOG_DIR, SYSPROP_LOG4J_CONFIGURATION, TMP_DIR_PREFIX, UPGRADE_DIR, YARN_SERVICE_LOG4J_FILENAME

Constructor Summary

Constructors

Constructor	Description
AbstractProviderService()

Method Summary

Modifier and Type	Method	Description
void	buildContainerEnvironment(AbstractLauncher launcher, Service service, ComponentInstance instance, SliderFileSystem fileSystem, org.apache.hadoop.conf.Configuration yarnConf, org.apache.hadoop.yarn.api.records.Container container, ContainerLaunchService.ComponentLaunchContext compLaunchContext, Map<String,String> tokensForSubstitution)
void	buildContainerLaunchCommand(AbstractLauncher launcher, Service service, ComponentInstance instance, SliderFileSystem fileSystem, org.apache.hadoop.conf.Configuration yarnConf, org.apache.hadoop.yarn.api.records.Container container, ContainerLaunchService.ComponentLaunchContext compLaunchContext, Map<String,String> tokensForSubstitution)
ProviderService.ResolvedLaunchParams	buildContainerLaunchContext(AbstractLauncher launcher, Service service, ComponentInstance instance, SliderFileSystem fileSystem, org.apache.hadoop.conf.Configuration yarnConf, org.apache.hadoop.yarn.api.records.Container container, ContainerLaunchService.ComponentLaunchContext compLaunchContext)	Set up the entire container launch context
void	buildContainerRetry(AbstractLauncher launcher, org.apache.hadoop.conf.Configuration yarnConf, ContainerLaunchService.ComponentLaunchContext compLaunchContext, ComponentInstance instance)
Map<String,String>	buildContainerTokens(ComponentInstance instance, org.apache.hadoop.yarn.api.records.Container container, ContainerLaunchService.ComponentLaunchContext compLaunchContext)
abstract void	processArtifact(AbstractLauncher launcher, ComponentInstance compInstance, SliderFileSystem fileSystem, Service service, ContainerLaunchService.ComponentLaunchContext compLaunchCtx)

Methods inherited from class java.lang.Object

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

Field Details

log

protected static final org.slf4j.Logger log

Constructor Details

AbstractProviderService

public AbstractProviderService()

Method Details

processArtifact

public abstract void processArtifact(AbstractLauncher launcher,
 ComponentInstance compInstance,
 SliderFileSystem fileSystem,
 Service service,
 ContainerLaunchService.ComponentLaunchContext compLaunchCtx)
                              throws IOException

Throws:

IOException

buildContainerTokens

public Map<String,String> buildContainerTokens(ComponentInstance instance,
 org.apache.hadoop.yarn.api.records.Container container,
 ContainerLaunchService.ComponentLaunchContext compLaunchContext)

buildContainerEnvironment

public void buildContainerEnvironment(AbstractLauncher launcher,
 Service service,
 ComponentInstance instance,
 SliderFileSystem fileSystem,
 org.apache.hadoop.conf.Configuration yarnConf,
 org.apache.hadoop.yarn.api.records.Container container,
 ContainerLaunchService.ComponentLaunchContext compLaunchContext,
 Map<String,String> tokensForSubstitution)
                               throws IOException,
SliderException

Throws:

IOException

SliderException

buildContainerLaunchCommand

public void buildContainerLaunchCommand(AbstractLauncher launcher,
 Service service,
 ComponentInstance instance,
 SliderFileSystem fileSystem,
 org.apache.hadoop.conf.Configuration yarnConf,
 org.apache.hadoop.yarn.api.records.Container container,
 ContainerLaunchService.ComponentLaunchContext compLaunchContext,
 Map<String,String> tokensForSubstitution)
                                 throws IOException,
SliderException

Throws:

IOException

SliderException

buildContainerRetry

public void buildContainerRetry(AbstractLauncher launcher,
 org.apache.hadoop.conf.Configuration yarnConf,
 ContainerLaunchService.ComponentLaunchContext compLaunchContext,
 ComponentInstance instance)

buildContainerLaunchContext

public ProviderService.ResolvedLaunchParams buildContainerLaunchContext(AbstractLauncher launcher,
 Service service,
 ComponentInstance instance,
 SliderFileSystem fileSystem,
 org.apache.hadoop.conf.Configuration yarnConf,
 org.apache.hadoop.yarn.api.records.Container container,
 ContainerLaunchService.ComponentLaunchContext compLaunchContext)
                                                                 throws IOException,
SliderException

Description copied from interface: ProviderService

Set up the entire container launch context

Specified by:

buildContainerLaunchContext in interface ProviderService

Throws:

IOException

SliderException