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 Description voidSlot. 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 Description classLocalizedResourceRepresents a resource that is localized on the supervisor.classLocallyCachedTopologyBlobA locally cached blob for the topology.Methods in org.apache.storm.localizer that return types with arguments of type LocallyCachedBlob Modifier and Type Method 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 Description voidBlobChangingCallback. 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 Description voidLocalizedResourceRetentionSet. addResources(ConcurrentMap<String,? extends LocallyCachedBlob> blobs)Add blobs to be checked if they can be deleted.
-