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

Class ResourceSet

java.lang.Object

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

public class ResourceSet
extends Object

All Resources requested by the container.

Constructor Summary

Constructors

Constructor	Description
ResourceSet()

Method Summary

Modifier and Type	Method	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.

Methods inherited from class java.lang.Object

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

Constructor Details

ResourceSet

public ResourceSet()

Method Details

addResources

public Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> addResources(Map<String,org.apache.hadoop.yarn.api.records.LocalResource> localResourceMap)
                                                                                                              throws URISyntaxException

Throws:

URISyntaxException

resourceLocalized

public Set<String> resourceLocalized(LocalResourceRequest request,
 org.apache.hadoop.fs.Path location)

Called when resource localized.

Parameters:

request - The original request for the localized resource

location - The path where the resource is localized

Returns:

The list of symlinks for the localized resources.

resourceLocalizationFailed

public void resourceLocalizationFailed(LocalResourceRequest request,
 String diagnostics)

getAllResourcesByVisibility

public Map<org.apache.hadoop.yarn.api.records.LocalResourceVisibility,Collection<LocalResourceRequest>> getAllResourcesByVisibility()

getLocalizedResources

public Map<org.apache.hadoop.fs.Path,List<String>> getLocalizedResources()

getResourcesToBeUploaded

public Map<LocalResourceRequest,org.apache.hadoop.fs.Path> getResourcesToBeUploaded()

getResourcesUploadPolicies

public Map<LocalResourceRequest,Boolean> getResourcesUploadPolicies()

getPendingResources

public Map<LocalResourceRequest,Set<String>> getPendingResources()

merge

public static ResourceSet merge(ResourceSet... resourceSets)

getLocalizationStatuses

public List<org.apache.hadoop.yarn.api.records.LocalizationStatus> getLocalizationStatuses()

Get all the localization statuses.

Returns:

the localization statuses.