Package | Description |
---|---|
org.apache.storm.blobstore | |
org.apache.storm.hdfs.blobstore | |
org.apache.storm.localizer | |
org.apache.storm.utils |
Modifier and Type | Class and Description |
---|---|
class |
NimbusBlobStore
NimbusBlobStore is a USER facing client API to perform basic operations such as create, update, delete and read for local and hdfs blob store.
|
Modifier and Type | Class and Description |
---|---|
class |
HdfsClientBlobStore
Client to access the HDFS blobStore.
|
Modifier and Type | Method and Description |
---|---|
protected ClientBlobStore |
Localizer.getClientBlobStore() |
Modifier and Type | Method and Description |
---|---|
protected boolean |
Localizer.isLocalizedResourceUpToDate(LocalizedResource lrsrc,
ClientBlobStore blobstore) |
Modifier and Type | Method and Description |
---|---|
static ClientBlobStore |
Utils.getClientBlobStore(Map conf) |
static ClientBlobStore |
Utils.getClientBlobStoreForSupervisor(Map conf) |
Modifier and Type | Method and Description |
---|---|
static void |
Utils.downloadResourcesAsSupervisor(String key,
String localFile,
ClientBlobStore cb)
Meant to be called only by the supervisor for stormjar/stormconf/stormcode files.
|
void |
Utils.downloadResourcesAsSupervisorImpl(String key,
String localFile,
ClientBlobStore cb) |
static long |
Utils.nimbusVersionOfBlob(String key,
ClientBlobStore cb) |
Copyright © 2019 The Apache Software Foundation. All Rights Reserved.