Uses of Interface
org.apache.storm.localizer.BlobChangingCallback
Packages that use BlobChangingCallback
- 
Uses of BlobChangingCallback in org.apache.storm.daemon.supervisorClasses in org.apache.storm.daemon.supervisor that implement BlobChangingCallback
- 
Uses of BlobChangingCallback in org.apache.storm.localizerMethods in org.apache.storm.localizer with parameters of type BlobChangingCallbackModifier and TypeMethodDescriptionvoidLocallyCachedBlob.addReference(PortAndAssignment pna, BlobChangingCallback cb) Mark that a given port and assignment are using this.voidAsyncLocalizer.recoverRunningTopology(LocalAssignment currentAssignment, int port, BlobChangingCallback cb) Do everything needed to recover the state in the AsyncLocalizer for a running topology.AsyncLocalizer.requestDownloadTopologyBlobs(LocalAssignment assignment, int port, BlobChangingCallback cb) Request that all of the blobs necessary for this topology be downloaded.