Class BlobStore

java.lang.Object
org.apache.storm.blobstore.BlobStore
All Implemented Interfaces:
AutoCloseable, Shutdownable
Direct Known Subclasses:
HdfsBlobStore, LocalFsBlobStore

public abstract class BlobStore extends Object implements Shutdownable, AutoCloseable
Provides a way to store blobs that can be downloaded. Blobs must be able to be uploaded and listed from Nimbus, and downloaded from the Supervisors. It is a key value based store. Key being a string and value being the blob data.

ACL checking must take place against the provided subject. If the blob store does not support Security it must validate that all ACLs set are always WORLD, everything.

The users can upload their blobs through the blob store command line. The command line also allows us to update and delete blobs.

Modifying the replication factor only works for HdfsBlobStore as for the LocalFsBlobStore the replication is dependent on the number of Nimbodes available.