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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
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 Detail
-
blobChanging
void 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.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.
-
-