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 Type	Method and 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.