Uses of Interface
org.apache.storm.localizer.BlobChangingCallback
-
Packages that use BlobChangingCallback Package Description org.apache.storm.daemon.supervisor org.apache.storm.localizer -
-
Uses of BlobChangingCallback in org.apache.storm.daemon.supervisor
Classes in org.apache.storm.daemon.supervisor that implement BlobChangingCallback Modifier and Type Class Description class
Slot
-
Uses of BlobChangingCallback in org.apache.storm.localizer
Methods in org.apache.storm.localizer with parameters of type BlobChangingCallback Modifier and Type Method Description void
LocallyCachedBlob. addReference(PortAndAssignment pna, BlobChangingCallback cb)
Mark that a given port and assignment are using this.void
AsyncLocalizer. recoverRunningTopology(LocalAssignment currentAssignment, int port, BlobChangingCallback cb)
Do everything needed to recover the state in the AsyncLocalizer for a running topology.CompletableFuture<Void>
AsyncLocalizer. requestDownloadTopologyBlobs(LocalAssignment assignment, int port, BlobChangingCallback cb)
Request that all of the blobs necessary for this topology be downloaded.
-