Package | Description |
---|---|
org.apache.storm.daemon.supervisor | |
org.apache.storm.localizer |
Class and Description |
---|
AsyncLocalizer
Downloads and caches blobs locally.
|
BlobChangingCallback
Callback for when a localized blob is going to change.
|
GoodToGo
Used as a way to give feedback that the listener is ready for the caller to change the blob.
|
LocallyCachedBlob
Represents a blob that is cached locally on disk by the supervisor.
|
LocalResource
Local Resource requested by the topology.
|
Class and Description |
---|
BlobChangingCallback
Callback for when a localized blob is going to change.
|
GoodToGo
Used as a way to give feedback that the listener is ready for the caller to change the blob.
|
GoodToGo.GoodToGoLatch |
IOFunction |
LocalizedResource
Represents a resource that is localized on the supervisor.
|
LocallyCachedBlob
Represents a blob that is cached locally on disk by the supervisor.
|
LocallyCachedTopologyBlob.TopologyBlobType |
PortAndAssignment |
Copyright © 2022 The Apache Software Foundation. All rights reserved.