Package org.apache.storm.localizer
Class LocalizedResourceRetentionSet
java.lang.Object
org.apache.storm.localizer.LocalizedResourceRetentionSet
A set of resources that we can look at to see which ones we retain and which ones should be
 removed.
- 
Field SummaryFields
- 
Method SummaryModifier and TypeMethodDescriptionvoidaddResources(ConcurrentMap<String, ? extends LocallyCachedBlob> blobs) Add blobs to be checked if they can be deleted.cleanup(ClientBlobStore store) Actually cleanup the blobs to try and get below the target cache size.protected inttoString()
- 
Field Details- 
LOGpublic static final org.slf4j.Logger LOG
 
- 
- 
Method Details- 
getSizeWithNoReferencesprotected int getSizeWithNoReferences()
- 
addResourcesAdd blobs to be checked if they can be deleted.- Parameters:
- blobs- a map of blob name to the blob object. The blobs in this map will be deleted from the map if they are deleted on disk too.
 
- 
cleanupActually cleanup the blobs to try and get below the target cache size.- Parameters:
- store- the blobs store client used to check if the blob has been deleted from the blobstore. If it has, the blob will be deleted even if the cache is not over the target size.
- Returns:
- a set containing any deleted blobs.
 
- 
toString
 
-