Uses of Class
org.apache.storm.localizer.LocallyCachedBlob
Packages that use LocallyCachedBlob
-
Uses of LocallyCachedBlob in org.apache.storm.daemon.supervisor
Methods in org.apache.storm.daemon.supervisor with parameters of type LocallyCachedBlobModifier and TypeMethodDescriptionvoid
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.localizerModifier and TypeClassDescriptionclass
Represents a resource that is localized on the supervisor.class
A locally cached blob for the topology.Methods in org.apache.storm.localizer that return types with arguments of type LocallyCachedBlobModifier and TypeMethodDescriptionLocalizedResourceRetentionSet.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 LocallyCachedBlobModifier 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.Method parameters in org.apache.storm.localizer with type arguments of type LocallyCachedBlobModifier and TypeMethodDescriptionvoid
LocalizedResourceRetentionSet.addResources
(ConcurrentMap<String, ? extends LocallyCachedBlob> blobs) Add blobs to be checked if they can be deleted.