public class ResourceLocalizationService extends org.apache.hadoop.service.CompositeService implements org.apache.hadoop.yarn.event.EventHandler<LocalizationEvent>, LocalizationProtocol
Modifier and Type | Field and Description |
---|---|
protected org.apache.hadoop.yarn.event.Dispatcher |
dispatcher |
static String |
NM_PRIVATE_DIR |
static org.apache.hadoop.fs.permission.FsPermission |
NM_PRIVATE_PERM |
Constructor and Description |
---|
ResourceLocalizationService(org.apache.hadoop.yarn.event.Dispatcher dispatcher,
ContainerExecutor exec,
DeletionService delService,
LocalDirsHandlerService dirsHandler,
Context context,
NodeManagerMetrics metrics) |
Modifier and Type | Method and 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() |
addIfService, addService, getServices, removeService
close, getBlockers, getConfig, getFailureCause, getFailureState, getLifecycleHistory, getName, getServiceState, getStartTime, init, isInState, noteFailure, putBlocker, registerGlobalListener, registerServiceListener, removeBlocker, setConfig, start, stop, toString, unregisterGlobalListener, unregisterServiceListener, waitForServiceToStop
public static final String NM_PRIVATE_DIR
public static final org.apache.hadoop.fs.permission.FsPermission NM_PRIVATE_PERM
protected final org.apache.hadoop.yarn.event.Dispatcher dispatcher
public ResourceLocalizationService(org.apache.hadoop.yarn.event.Dispatcher dispatcher, ContainerExecutor exec, DeletionService delService, LocalDirsHandlerService dirsHandler, Context context, NodeManagerMetrics metrics)
public void serviceInit(org.apache.hadoop.conf.Configuration conf) throws Exception
serviceInit
in class org.apache.hadoop.service.CompositeService
Exception
public void recoverLocalizedResources(NMStateStoreService.RecoveredLocalizationState state) throws URISyntaxException, IOException
URISyntaxException
IOException
public LocalizerHeartbeatResponse heartbeat(LocalizerStatus status)
heartbeat
in interface LocalizationProtocol
public void serviceStart() throws Exception
serviceStart
in class org.apache.hadoop.service.CompositeService
Exception
public void serviceStop() throws Exception
serviceStop
in class org.apache.hadoop.service.CompositeService
Exception
public void handle(LocalizationEvent event)
handle
in interface org.apache.hadoop.yarn.event.EventHandler<LocalizationEvent>
@InterfaceAudience.Private public org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService.PublicLocalizer getPublicLocalizer()
@InterfaceAudience.Private public org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService.LocalizerRunner getLocalizerRunner(String locId)
@InterfaceAudience.Private public Map<String,org.apache.hadoop.yarn.server.nodemanager.containermanager.localizer.ResourceLocalizationService.LocalizerRunner> getPrivateLocalizers()
public LocalizedResource getLocalizedResource(LocalResourceRequest req, String user, org.apache.hadoop.yarn.api.records.ApplicationId appId)
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.