Interface | Description |
---|---|
BlobChangingCallback |
Callback for when a localized blob is going to change.
|
IOFunction<T,R> | |
PortAndAssignment |
Class | Description |
---|---|
AsyncLocalizer |
Downloads and caches blobs locally.
|
GoodToGo |
Used as a way to give feedback that the listener is ready for the caller to change the blob.
|
GoodToGo.GoodToGoLatch | |
LocalizedResource |
Represents a resource that is localized on the supervisor.
|
LocalizedResourceRetentionSet |
A set of resources that we can look at to see which ones we retain and which ones should be removed.
|
LocallyCachedBlob |
Represents a blob that is cached locally on disk by the supervisor.
|
LocallyCachedTopologyBlob |
A locally cached blob for the topology.
|
LocalResource |
Local Resource requested by the topology.
|
TimePortAndAssignment |
Enum | Description |
---|---|
LocallyCachedTopologyBlob.TopologyBlobType |
Copyright © 2022 The Apache Software Foundation. All rights reserved.