Package | Description |
---|---|
org.apache.storm.daemon.supervisor | |
org.apache.storm.localizer |
Modifier and Type | Method and Description |
---|---|
void |
Slot.blobChanging(LocalAssignment assignment,
int port,
LocallyCachedBlob blob,
GoodToGo go) |
Modifier and Type | Class and Description |
---|---|
class |
LocalizedResource
Represents a resource that is localized on the supervisor.
|
class |
LocallyCachedTopologyBlob
A locally cached blob for the topology.
|
Modifier and Type | Method and Description |
---|---|
void |
BlobChangingCallback.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.
|
Modifier and Type | Method and Description |
---|---|
void |
LocalizedResourceRetentionSet.addResources(ConcurrentMap<String,? extends LocallyCachedBlob> blobs)
Add blobs to be checked if they can be deleted.
|
Copyright © 2019 The Apache Software Foundation. All rights reserved.