Uses of Interface
org.apache.storm.localizer.BlobChangingCallback
-
Uses of BlobChangingCallback in org.apache.storm.daemon.supervisor
-
Uses of BlobChangingCallback in org.apache.storm.localizer
Modifier and TypeMethodDescriptionvoid
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.AsyncLocalizer.requestDownloadTopologyBlobs
(LocalAssignment assignment, int port, BlobChangingCallback cb) Request that all of the blobs necessary for this topology be downloaded.