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 TypeMethodDescriptionvoidSlot.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 TypeClassDescriptionclassRepresents a resource that is localized on the supervisor.classA 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 TypeMethodDescriptionvoidBlobChangingCallback.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 TypeMethodDescriptionvoidLocalizedResourceRetentionSet.addResources(ConcurrentMap<String, ? extends LocallyCachedBlob> blobs) Add blobs to be checked if they can be deleted.