Uses of Class
org.apache.storm.localizer.LocalizedResource

Packages that use LocalizedResource

Package	Description
org.apache.storm.localizer

Uses of LocalizedResource in org.apache.storm.localizer

Methods in org.apache.storm.localizer that return LocalizedResource

Modifier and Type	Method and Description
LocalizedResource	LocalizedResourceSet.get(String name, boolean uncompress)
LocalizedResource	Localizer.getBlob(LocalResource localResource, String user, String topo, File userFileDir) This function either returns the blob in the existing cache or if it doesn’t exist in the cache, it will download the blob and will block until the download is complete.

Methods in org.apache.storm.localizer that return types with arguments of type LocalizedResource

Modifier and Type	Method and Description
List<LocalizedResource>	Localizer.getBlobs(List<LocalResource> localResources, String user, String topo, File userFileDir) This function either returns the blobs in the existing cache or if they don’t exist in the cache, it downloads them in parallel (up to SUPERVISOR_BLOBSTORE_DOWNLOAD_THREAD_COUNT) and will block until all of them have been downloaded
Iterator<LocalizedResource>	LocalizedResourceSet.getLocalArchivesIterator()
Iterator<LocalizedResource>	LocalizedResourceSet.getLocalFilesIterator()
List<LocalizedResource>	Localizer.updateBlobs(List<LocalResource> localResources, String user) This function updates blobs on the supervisor.

Methods in org.apache.storm.localizer with parameters of type LocalizedResource

Modifier and Type	Method and Description
void	LocalizedResourceSet.add(String resourceName, LocalizedResource newResource, boolean uncompress)
protected boolean	LocalizedResourceRetentionSet.deleteResource(LocalizedResource resource)
protected boolean	Localizer.isLocalizedResourceDownloaded(LocalizedResource lrsrc)
protected boolean	Localizer.isLocalizedResourceUpToDate(LocalizedResource lrsrc, ClientBlobStore blobstore)
void	LocalizedResourceSet.putIfAbsent(String resourceName, LocalizedResource updatedResource, boolean uncompress)
boolean	LocalizedResourceSet.remove(LocalizedResource resource)

Method parameters in org.apache.storm.localizer with type arguments of type LocalizedResource

Modifier and Type	Method and Description
protected void	LocalizedResourceRetentionSet.addResourcesForSet(Iterator<LocalizedResource> setIter, LocalizedResourceSet set)