Modifier and Type | Method and Description |
---|---|
LocalResourceRequest |
ContainerResourceEvent.getResource() |
Constructor and Description |
---|
ContainerResourceEvent(org.apache.hadoop.yarn.api.records.ContainerId container,
ContainerEventType type,
LocalResourceRequest rsrc) |
ContainerResourceFailedEvent(org.apache.hadoop.yarn.api.records.ContainerId container,
LocalResourceRequest rsrc,
String diagnosticMesage) |
ContainerResourceLocalizedEvent(org.apache.hadoop.yarn.api.records.ContainerId container,
LocalResourceRequest rsrc,
org.apache.hadoop.fs.Path loc) |
Modifier and Type | Method and Description |
---|---|
LocalResourceRequest |
LocalizedResource.getRequest() |
Modifier and Type | Method and Description |
---|---|
Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> |
ResourceSet.addResources(Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResourceMap) |
Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> |
ResourceSet.getAllResourcesByVisibility() |
Map<LocalResourceRequest,Set<String>> |
ResourceSet.getPendingResources() |
Map<LocalResourceRequest,org.apache.hadoop.fs.Path> |
ResourceSet.getResourcesToBeUploaded() |
Map<LocalResourceRequest,Boolean> |
ResourceSet.getResourcesUploadPolicies() |
Modifier and Type | Method and Description |
---|---|
int |
LocalResourceRequest.compareTo(LocalResourceRequest other) |
LocalizedResource |
ResourceLocalizationService.getLocalizedResource(LocalResourceRequest req,
String user,
org.apache.hadoop.yarn.api.records.ApplicationId appId) |
void |
ResourceSet.resourceLocalizationFailed(LocalResourceRequest request,
String diagnostics) |
Set<String> |
ResourceSet.resourceLocalized(LocalResourceRequest request,
org.apache.hadoop.fs.Path location)
Called when resource localized.
|
Constructor and Description |
---|
LocalizedResource(LocalResourceRequest rsrc,
org.apache.hadoop.yarn.event.Dispatcher dispatcher) |
Modifier and Type | Method and Description |
---|---|
LocalResourceRequest |
ResourceEvent.getLocalResourceRequest() |
Modifier and Type | Method and Description |
---|---|
Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> |
ContainerLocalizationRequestEvent.getRequestedResources() |
Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> |
ContainerLocalizationCleanupEvent.getResources() |
Constructor and Description |
---|
ResourceEvent(LocalResourceRequest rsrc,
ResourceEventType type) |
ResourceFailedLocalizationEvent(LocalResourceRequest rsrc,
String diagnosticMesage) |
ResourceLocalizedEvent(LocalResourceRequest rsrc,
org.apache.hadoop.fs.Path location,
long size) |
ResourceRecoveredEvent(LocalResourceRequest rsrc,
org.apache.hadoop.fs.Path localPath,
long size) |
ResourceReleaseEvent(LocalResourceRequest rsrc,
org.apache.hadoop.yarn.api.records.ContainerId container) |
ResourceRequestEvent(LocalResourceRequest resource,
org.apache.hadoop.yarn.api.records.LocalResourceVisibility vis,
LocalizerContext context) |
Constructor and Description |
---|
ContainerLocalizationCleanupEvent(Container c,
Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> rsrc)
Event requesting the cleanup of the rsrc.
|
ContainerLocalizationRequestEvent(Container c,
Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> rsrc)
Event requesting the localization of the rsrc.
|
Modifier and Type | Method and Description |
---|---|
Map<LocalResourceRequest,org.apache.hadoop.fs.Path> |
SharedCacheUploadEvent.getResources() |
Constructor and Description |
---|
SharedCacheUploadEvent(Map<LocalResourceRequest,org.apache.hadoop.fs.Path> resources,
org.apache.hadoop.yarn.api.records.ContainerLaunchContext context,
String user,
SharedCacheUploadEventType eventType) |
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.