Package | Description |
---|---|
org.apache.storm.daemon.supervisor | |
org.apache.storm.localizer |
Modifier and Type | Method and Description |
---|---|
static List<LocalResource> |
SupervisorUtils.blobstoreMapToLocalresources(Map<String,Map<String,Object>> blobstoreMap)
Returns a list of LocalResources based on the blobstore-map passed in
|
Modifier and Type | Method and Description |
---|---|
LocalizedResource |
Localizer.getBlob(LocalResource localResource,
String user,
String topo,
File userFileDir)
This function either returns the blob in the existing cache or if it doesn’t exist in the cache, it will download the blob and will block until the download is complete.
|
Modifier and Type | Method and Description |
---|---|
void |
Localizer.addReferences(List<LocalResource> localresource,
String user,
String topo) |
List<LocalizedResource> |
Localizer.getBlobs(List<LocalResource> localResources,
String user,
String topo,
File userFileDir)
This function either returns the blobs in the existing cache or if they don’t exist in the cache, it downloads them in parallel (up to SUPERVISOR_BLOBSTORE_DOWNLOAD_THREAD_COUNT) and will block until all of them have been downloaded
|
List<LocalizedResource> |
Localizer.updateBlobs(List<LocalResource> localResources,
String user)
This function updates blobs on the supervisor.
|
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.