Package org.apache.storm.blobstore
Class FileBlobStoreImpl
java.lang.Object
org.apache.storm.blobstore.FileBlobStoreImpl
Very basic blob store impl with no ACL handling.
- 
Nested Class SummaryNested Classes
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionprotected voidvoidDelete a key from the blob store.booleanCheck if the key exists in the blob store.voidfullCleanup(long age) protected Iterator<LocalFsBlobStoreFile>listBlobStoreFiles(File path) listKeys()List keys.Get an input stream for reading a part.voidshutdown()Get an object tied to writing the data.
- 
Constructor Details- 
FileBlobStoreImpl- Throws:
- IOException
 
 
- 
- 
Method Details- 
listKeysList keys.- Returns:
- all keys that are available for reading
- Throws:
- IOException- on any error
 
- 
listKeys- Throws:
- IOException
 
- 
readGet an input stream for reading a part.- Parameters:
- key- the key of the part to read.
- Returns:
- the where to read the data from.
- Throws:
- IOException- on any error
 
- 
writeGet an object tied to writing the data.- Parameters:
- key- the key of the part to write to.
- Returns:
- an object that can be used to both write to, but also commit/cancel the operation.
- Throws:
- IOException- on any error
 
- 
existsCheck if the key exists in the blob store.- Parameters:
- key- the key to check for
- Returns:
- true if it exists else false.
 
- 
deleteKeyDelete a key from the blob store.- Parameters:
- key- the key to delete
- Throws:
- IOException- on any error
 
- 
fullCleanup- Throws:
- IOException
 
- 
listBlobStoreFiles- Throws:
- IOException
 
- 
delete- Throws:
- IOException
 
- 
shutdownpublic void shutdown()
 
-