Uses of Class
org.apache.storm.localizer.LocallyCachedBlob
-
Uses of LocallyCachedBlob in org.apache.storm.daemon.supervisor
Modifier and TypeMethodDescriptionvoid
Slot.blobChanging
(LocalAssignment assignment, int port, LocallyCachedBlob blob, GoodToGo go) -
Uses of LocallyCachedBlob in org.apache.storm.localizer
Modifier and TypeClassDescriptionclass
Represents a resource that is localized on the supervisor.class
A locally cached blob for the topology.Modifier and TypeMethodDescriptionLocalizedResourceRetentionSet.cleanup
(ClientBlobStore store) Actually cleanup the blobs to try and get below the target cache size.Modifier and TypeMethodDescriptionvoid
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.Modifier and TypeMethodDescriptionvoid
LocalizedResourceRetentionSet.addResources
(ConcurrentMap<String, ? extends LocallyCachedBlob> blobs) Add blobs to be checked if they can be deleted.