Package org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer

Class ResourceLocalizationService

java.lang.Object

org.apache.hadoop.service.AbstractService

org.apache.hadoop.service.CompositeService

org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService

All Implemented Interfaces:

Closeable, AutoCloseable, org.apache.hadoop.service.Service, org.apache.hadoop.yarn.event.EventHandler<LocalizationEvent>, LocalizationProtocol

public class ResourceLocalizationService
extends org.apache.hadoop.service.CompositeService
implements org.apache.hadoop.yarn.event.EventHandler<LocalizationEvent>, LocalizationProtocol

Nested Class Summary

Nested classes/interfaces inherited from class org.apache.hadoop.service.CompositeService

org.apache.hadoop.service.CompositeService.CompositeServiceShutdownHook

Nested classes/interfaces inherited from interface org.apache.hadoop.service.Service

org.apache.hadoop.service.Service.STATE

Field Summary

Fields

Modifier and Type	Field	Description
protected final org.apache.hadoop.yarn.event.Dispatcher	dispatcher
static final String	NM_PRIVATE_DIR
static final org.apache.hadoop.fs.permission.FsPermission	NM_PRIVATE_PERM

Fields inherited from class org.apache.hadoop.service.CompositeService

STOP_ONLY_STARTED_SERVICES

Constructor Summary

Constructors

Constructor	Description
ResourceLocalizationService(org.apache.hadoop.yarn.event.Dispatcher dispatcher, ContainerExecutor exec, DeletionService delService, LocalDirsHandlerService dirsHandler, Context context, NodeManagerMetrics metrics)

Method Summary

Modifier and Type	Method	Description
LocalizedResource	getLocalizedResource(LocalResourceRequest req, String user, org.apache.hadoop.yarn.api.records.ApplicationId appId)
org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService.LocalizerRunner	getLocalizerRunner(String locId)
Map<String,org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService.LocalizerRunner>	getPrivateLocalizers()
org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService.PublicLocalizer	getPublicLocalizer()
void	handle(LocalizationEvent event)
LocalizerHeartbeatResponse	heartbeat(LocalizerStatus status)
void	recoverLocalizedResources(NMStateStoreService.RecoveredLocalizationState state)
void	serviceInit(org.apache.hadoop.conf.Configuration conf)
void	serviceStart()
void	serviceStop()

Methods inherited from class org.apache.hadoop.service.CompositeService

addIfService, addService, getServices, removeService

Methods inherited from class org.apache.hadoop.service.AbstractService

close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop

Methods inherited from class java.lang.Object

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

Field Details

NM_PRIVATE_DIR

public static final String NM_PRIVATE_DIR

See Also:

• Constant Field Values

NM_PRIVATE_PERM

public static final org.apache.hadoop.fs.permission.FsPermission NM_PRIVATE_PERM

dispatcher

protected final org.apache.hadoop.yarn.event.Dispatcher dispatcher

Constructor Details

ResourceLocalizationService

public ResourceLocalizationService(org.apache.hadoop.yarn.event.Dispatcher dispatcher,
 ContainerExecutor exec,
 DeletionService delService,
 LocalDirsHandlerService dirsHandler,
 Context context,
 NodeManagerMetrics metrics)

Method Details

serviceInit

public void serviceInit(org.apache.hadoop.conf.Configuration conf)
                 throws Exception

Overrides:

serviceInit in class org.apache.hadoop.service.CompositeService

Throws:

Exception

recoverLocalizedResources

public void recoverLocalizedResources(NMStateStoreService.RecoveredLocalizationState state)
                               throws URISyntaxException,
IOException

Throws:

URISyntaxException

IOException

heartbeat

public LocalizerHeartbeatResponse heartbeat(LocalizerStatus status)

Specified by:

heartbeat in interface LocalizationProtocol

serviceStart

public void serviceStart()
                  throws Exception

Overrides:

serviceStart in class org.apache.hadoop.service.CompositeService

Throws:

Exception

serviceStop

public void serviceStop()
                 throws Exception

Overrides:

serviceStop in class org.apache.hadoop.service.CompositeService

Throws:

Exception

handle

public void handle(LocalizationEvent event)

Specified by:

handle in interface org.apache.hadoop.yarn.event.EventHandler<LocalizationEvent>

getPublicLocalizer

@VisibleForTesting
@Private
public org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService.PublicLocalizer getPublicLocalizer()

getLocalizerRunner

@VisibleForTesting
@Private
public org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService.LocalizerRunner getLocalizerRunner(String locId)

getPrivateLocalizers

@VisibleForTesting
@Private
public Map<String,org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService.LocalizerRunner> getPrivateLocalizers()

getLocalizedResource

public LocalizedResource getLocalizedResource(LocalResourceRequest req,
 String user,
 org.apache.hadoop.yarn.api.records.ApplicationId appId)