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 classLocalModeClientBlobStoreA Client blob store for LocalMode.classNimbusBlobStoreNimbusBlobStore 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 voidClientBlobStore.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 classHdfsClientBlobStoreClient 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 ClientBlobStoreAsyncLocalizer. 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.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 ClientBlobStore Modifier and Type Method Description static ClientBlobStoreUtils. getClientBlobStore(Map<String,Object> conf)static ClientBlobStoreServerUtils. getClientBlobStoreForSupervisor(Map<String,Object> conf)Methods in org.apache.storm.utils with parameters of type ClientBlobStore Modifier and Type Method Description static longServerUtils. nimbusVersionOfBlob(String key, ClientBlobStore cb)
-