public class ResourceSet extends Object
Constructor and Description |
---|
ResourceSet() |
Modifier and Type | Method and Description |
---|---|
Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> |
addResources(Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResourceMap) |
Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> |
getAllResourcesByVisibility() |
List<org.apache.hadoop.yarn.api.records.LocalizationStatus> |
getLocalizationStatuses()
Get all the localization statuses.
|
Map<org.apache.hadoop.fs.Path,List<String>> |
getLocalizedResources() |
Map<LocalResourceRequest,Set<String>> |
getPendingResources() |
Map<LocalResourceRequest,org.apache.hadoop.fs.Path> |
getResourcesToBeUploaded() |
Map<LocalResourceRequest,Boolean> |
getResourcesUploadPolicies() |
static ResourceSet |
merge(ResourceSet... resourceSets) |
void |
resourceLocalizationFailed(LocalResourceRequest request,
String diagnostics) |
Set<String> |
resourceLocalized(LocalResourceRequest request,
org.apache.hadoop.fs.Path location)
Called when resource localized.
|
public Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> addResources(Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResourceMap) throws URISyntaxException
URISyntaxException
public Set<String> resourceLocalized(LocalResourceRequest request, org.apache.hadoop.fs.Path location)
request
- The original request for the localized resourcelocation
- The path where the resource is localizedpublic void resourceLocalizationFailed(LocalResourceRequest request, String diagnostics)
public Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> getAllResourcesByVisibility()
public Map<LocalResourceRequest,org.apache.hadoop.fs.Path> getResourcesToBeUploaded()
public Map<LocalResourceRequest,Boolean> getResourcesUploadPolicies()
public Map<LocalResourceRequest,Set<String>> getPendingResources()
public static ResourceSet merge(ResourceSet... resourceSets)
public List<org.apache.hadoop.yarn.api.records.LocalizationStatus> getLocalizationStatuses()
Copyright © 2008–2023 Apache Software Foundation. All rights reserved.