Package org.apache.storm.localizer
Interface BlobChangingCallback
- All Known Implementing Classes:
- Slot
public interface BlobChangingCallback
Callback for when a localized blob is going to change.
- 
Method SummaryModifier and TypeMethodDescriptionvoidblobChanging(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 Details- 
blobChangingInforms 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.If `go.getLatch()` is never called before the method completes it is assumed that the listener is good with the blob changing. - Parameters:
- assignment- the assignment this resource and callback are registered with.
- port- the port that this resource and callback are registered with.
- blob- the blob that is going to change.
- go- a way to indicate if the listener is ready for the resource to change.
 
 
-