Class HdfsClientBlobStore

java.lang.Object
org.apache.storm.blobstore.ClientBlobStore
org.apache.storm.hdfs.blobstore.HdfsClientBlobStore
All Implemented Interfaces:
AutoCloseable, Shutdownable

public class HdfsClientBlobStore extends ClientBlobStore
Client to access the HDFS blobStore. At this point, this is meant to only be used by the supervisor. Don't trust who the client says they are so pass null for all Subjects.

The HdfsBlobStore implementation takes care of the null Subjects. It assigns Subjects based on what hadoop says who the users are. These users must be configured accordingly in the SUPERVISOR_ADMINS for ACL validation and for the supervisors to download the blobs. This API is only used by the supervisor in order to talk directly to HDFS.