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 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 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 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 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 Description void
LocalizedResourceRetentionSet. addResources(ConcurrentMap<String,? extends LocallyCachedBlob> blobs)
Add blobs to be checked if they can be deleted.
-