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 Summary
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionprotected void
void
Delete a key from the blob store.boolean
Check if the key exists in the blob store.void
fullCleanup
(long age) protected Iterator<LocalFsBlobStoreFile>
listBlobStoreFiles
(File path) listKeys()
List keys.Get an input stream for reading a part.void
shutdown()
Get an object tied to writing the data.
-
Constructor Details
-
FileBlobStoreImpl
- Throws:
IOException
-
-
Method Details
-
listKeys
List keys.- Returns:
- all keys that are available for reading
- Throws:
IOException
- on any error
-
listKeys
- Throws:
IOException
-
read
Get 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
-
write
Get 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
-
exists
Check if the key exists in the blob store.- Parameters:
key
- the key to check for- Returns:
- true if it exists else false.
-
deleteKey
Delete 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
-
shutdown
public void shutdown()
-