Uses of Class
org.apache.storm.blobstore.ClientBlobStore
Packages that use ClientBlobStore
Package
Description
-
Uses of ClientBlobStore in org.apache.storm.blobstore
Subclasses of ClientBlobStore in org.apache.storm.blobstoreModifier and TypeClassDescriptionclassA Client blob store for LocalMode.classNimbusBlobStore 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 ClientBlobStoreModifier and TypeMethodDescriptionvoidClientBlobStore.WithBlobstore.run(ClientBlobStore blobStore) -
Uses of ClientBlobStore in org.apache.storm.hdfs.blobstore
Subclasses of ClientBlobStore in org.apache.storm.hdfs.blobstore -
Uses of ClientBlobStore in org.apache.storm.localizer
Methods in org.apache.storm.localizer that return ClientBlobStoreMethods in org.apache.storm.localizer with parameters of type ClientBlobStoreModifier and TypeMethodDescriptionLocalizedResourceRetentionSet.cleanup(ClientBlobStore store) Actually cleanup the blobs to try and get below the target cache size.protected org.apache.storm.localizer.LocallyCachedBlob.DownloadMetaLocallyCachedBlob.fetch(ClientBlobStore store, String key, IOFunction<Long, Path> pathSupplier, IOFunction<File, OutputStream> outStreamSupplier) Helper function to download blob from blob store.longLocalizedResource.fetchUnzipToTemp(ClientBlobStore store) abstract longLocallyCachedBlob.fetchUnzipToTemp(ClientBlobStore store) Download the latest version to a temp location.longLocallyCachedTopologyBlob.fetchUnzipToTemp(ClientBlobStore store) longLocalizedResource.getRemoteVersion(ClientBlobStore store) abstract longLocallyCachedBlob.getRemoteVersion(ClientBlobStore store) Get the version of the blob in the blob store.longLocallyCachedTopologyBlob.getRemoteVersion(ClientBlobStore store) voidLocallyCachedBlob.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 ClientBlobStoreModifier and TypeMethodDescriptionstatic ClientBlobStoreUtils.getClientBlobStore(Map<String, Object> conf) static ClientBlobStoreServerUtils.getClientBlobStoreForSupervisor(Map<String, Object> conf) Methods in org.apache.storm.utils with parameters of type ClientBlobStoreModifier and TypeMethodDescriptionstatic longServerUtils.nimbusVersionOfBlob(String key, ClientBlobStore cb)