Uses of Class
org.apache.storm.blobstore.ClientBlobStore
Package
Description
-
Uses of ClientBlobStore in org.apache.storm.blobstore
Modifier and TypeClassDescriptionclass
A Client blob store for LocalMode.class
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 TypeMethodDescriptionvoid
ClientBlobStore.WithBlobstore.run
(ClientBlobStore blobStore) -
Uses of ClientBlobStore in org.apache.storm.hdfs.blobstore
-
Uses of ClientBlobStore in org.apache.storm.localizer
Modifier and TypeMethodDescriptionLocalizedResourceRetentionSet.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
Modifier and TypeMethodDescriptionstatic ClientBlobStore
Utils.getClientBlobStore
(Map<String, Object> conf) static ClientBlobStore
ServerUtils.getClientBlobStoreForSupervisor
(Map<String, Object> conf) Modifier and TypeMethodDescriptionstatic long
ServerUtils.nimbusVersionOfBlob
(String key, ClientBlobStore cb)