Uses of Class
org.apache.storm.blobstore.ClientBlobStore

Packages that use ClientBlobStore

Package	Description
org.apache.storm.blobstore
org.apache.storm.hdfs.blobstore
org.apache.storm.localizer
org.apache.storm.utils

Uses of ClientBlobStore in org.apache.storm.blobstore

Subclasses of ClientBlobStore in org.apache.storm.blobstore

Modifier and Type	Class and Description
class	LocalModeClientBlobStore A Client blob store for LocalMode.
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.

Methods in org.apache.storm.blobstore with parameters of type ClientBlobStore

Modifier and Type	Method and Description
void	ClientBlobStore.WithBlobstore.run(ClientBlobStore blobStore)

Uses of ClientBlobStore in org.apache.storm.hdfs.blobstore

Subclasses of ClientBlobStore in org.apache.storm.hdfs.blobstore

Modifier and Type	Class and Description
class	HdfsClientBlobStore Client to access the HDFS blobStore.

Uses of ClientBlobStore in org.apache.storm.localizer

Methods in org.apache.storm.localizer that return ClientBlobStore

Modifier and Type	Method and Description
protected ClientBlobStore	AsyncLocalizer.getClientBlobStore()

Methods in org.apache.storm.localizer with parameters of type ClientBlobStore

Modifier and Type	Method and Description
void	LocalizedResourceRetentionSet.cleanup(ClientBlobStore store) Actually cleanup the blobs to try and get below the target cache size.
protected org.apache.storm.localizer.LocallyCachedBlob.DownloadMeta	LocallyCachedBlob.fetch(ClientBlobStore store, String key, IOFunction<Long,Path> pathSupplier, IOFunction<File,OutputStream> outStreamSupplier) Helper function to download blob from blob store.
abstract long	LocallyCachedBlob.fetchUnzipToTemp(ClientBlobStore store) Download the latest version to a temp location.
long	LocallyCachedTopologyBlob.fetchUnzipToTemp(ClientBlobStore store)
long	LocalizedResource.fetchUnzipToTemp(ClientBlobStore store)
abstract long	LocallyCachedBlob.getRemoteVersion(ClientBlobStore store) Get the version of the blob in the blob store.
long	LocallyCachedTopologyBlob.getRemoteVersion(ClientBlobStore store)
long	LocalizedResource.getRemoteVersion(ClientBlobStore store)

Uses of ClientBlobStore in org.apache.storm.utils

Methods in org.apache.storm.utils that return ClientBlobStore

Modifier and Type	Method and Description
static ClientBlobStore	Utils.getClientBlobStore(Map<String,Object> conf)
static ClientBlobStore	ServerUtils.getClientBlobStoreForSupervisor(Map<String,Object> conf)

Methods in org.apache.storm.utils with parameters of type ClientBlobStore

Modifier and Type	Method and Description
static void	ServerUtils.downloadResourcesAsSupervisor(String key, String localFile, ClientBlobStore cb) Meant to be called only by the supervisor for stormjar/stormconf/stormcode files.
void	ServerUtils.downloadResourcesAsSupervisorImpl(String key, String localFile, ClientBlobStore cb)
static long	ServerUtils.nimbusVersionOfBlob(String key, ClientBlobStore cb)