Interface BlobChangingCallback

  • All Known Implementing Classes:
    Slot

    public interface BlobChangingCallback
    Callback for when a localized blob is going to change.
    • 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.