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	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	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	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	Description
protected ClientBlobStore	AsyncLocalizer.getClientBlobStore()

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

Modifier and Type	Method	Description
Set<LocallyCachedBlob>	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.
long	LocalizedResource.fetchUnzipToTemp(ClientBlobStore store)
abstract long	LocallyCachedBlob.fetchUnzipToTemp(ClientBlobStore store)	Download the latest version to a temp location.
long	LocallyCachedTopologyBlob.fetchUnzipToTemp(ClientBlobStore store)
long	LocalizedResource.getRemoteVersion(ClientBlobStore store)
abstract long	LocallyCachedBlob.getRemoteVersion(ClientBlobStore store)	Get the version of the blob in the blob store.
long	LocallyCachedTopologyBlob.getRemoteVersion(ClientBlobStore store)
void	LocallyCachedBlob.update(ClientBlobStore blobStore, long remoteBlobstoreUpdateTime)	Checks and downloads a blob locally as necessary.

Uses of ClientBlobStore in org.apache.storm.utils

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

Modifier and Type	Method	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	Description
static long	ServerUtils.nimbusVersionOfBlob(String key, ClientBlobStore cb)