org.apache.storm.localizer

Class LocalizedResourceRetentionSet

java.lang.Object

org.apache.storm.localizer.LocalizedResourceRetentionSet

public class LocalizedResourceRetentionSet
extends Object

A set of resources that we can look at to see which ones we retain and which ones should be removed.

Field Summary

Fields

Modifier and Type	Field and Description
static org.slf4j.Logger	LOG

Method Summary

Modifier and Type	Method and Description
void	addResources(ConcurrentMap<String,? extends LocallyCachedBlob> blobs) Add blobs to be checked if they can be deleted.
Set<LocallyCachedBlob>	cleanup(ClientBlobStore store) Actually cleanup the blobs to try and get below the target cache size.
protected int	getSizeWithNoReferences()
String	toString()

Methods inherited from class java.lang.Object

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

Field Detail

LOG

public static final org.slf4j.Logger LOG

Method Detail

getSizeWithNoReferences

protected int getSizeWithNoReferences()

addResources

public void addResources(ConcurrentMap<String,? extends LocallyCachedBlob> blobs)

Add 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.

cleanup

public Set<LocallyCachedBlob> cleanup(ClientBlobStore store)

Actually 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

public String toString()

Overrides:

toString in class Object