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 Summary
Modifier and TypeMethodDescriptionvoid
blobChanging
(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
-
blobChanging
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.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.
-