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 and 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 and 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.