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

Packages that use LocallyCachedBlob

Package	Description
org.apache.storm.daemon.supervisor
org.apache.storm.localizer

Uses of LocallyCachedBlob in org.apache.storm.daemon.supervisor

Methods in org.apache.storm.daemon.supervisor with parameters of type LocallyCachedBlob

Modifier and Type	Method and Description
void	Slot.blobChanging(LocalAssignment assignment, int port, LocallyCachedBlob blob, GoodToGo go)

Uses of LocallyCachedBlob in org.apache.storm.localizer

Subclasses of LocallyCachedBlob in org.apache.storm.localizer

Modifier and Type	Class and Description
class	LocalizedResource Represents a resource that is localized on the supervisor.
class	LocallyCachedTopologyBlob A locally cached blob for the topology.

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

Modifier and Type	Method and Description
Set<LocallyCachedBlob>	LocalizedResourceRetentionSet.cleanup(ClientBlobStore store) Actually cleanup the blobs to try and get below the target cache size.

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

Modifier and Type	Method and Description
void	BlobChangingCallback.blobChanging(LocalAssignment assignment, int port, LocallyCachedBlob blob, GoodToGo go) Informs the listener that a blob has changed and is ready to update and replace a localized blob that has been marked as tied to the life cycle of the worker process.

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

Modifier and Type	Method and Description
void	LocalizedResourceRetentionSet.addResources(ConcurrentMap<String,? extends LocallyCachedBlob> blobs) Add blobs to be checked if they can be deleted.