Package org.apache.storm.hdfs.blobstore
Class HdfsBlobStoreFile
java.lang.Object
org.apache.storm.blobstore.BlobStoreFile
org.apache.storm.hdfs.blobstore.HdfsBlobStoreFile
-
Field Summary
Modifier and TypeFieldDescriptionstatic final org.apache.hadoop.fs.permission.FsPermission
Fields inherited from class org.apache.storm.blobstore.BlobStoreFile
BLOBSTORE_DATA_FILE, TMP_EXT, TMP_NAME_PATTERN
-
Constructor Summary
ConstructorDescriptionHdfsBlobStoreFile
(org.apache.hadoop.fs.Path base, boolean isTmp, boolean mustBeNew, org.apache.hadoop.conf.Configuration hconf) HdfsBlobStoreFile
(org.apache.hadoop.fs.Path base, String name, org.apache.hadoop.conf.Configuration hconf) -
Method Summary
Modifier and TypeMethodDescriptionvoid
cancel()
void
commit()
void
delete()
long
getKey()
long
boolean
isTmp()
void
setMetadata
(SettableBlobMeta meta) toString()
-
Field Details
-
BLOBSTORE_FILE_PERMISSION
public static final org.apache.hadoop.fs.permission.FsPermission BLOBSTORE_FILE_PERMISSION
-
-
Constructor Details
-
HdfsBlobStoreFile
public HdfsBlobStoreFile(org.apache.hadoop.fs.Path base, String name, org.apache.hadoop.conf.Configuration hconf) -
HdfsBlobStoreFile
public HdfsBlobStoreFile(org.apache.hadoop.fs.Path base, boolean isTmp, boolean mustBeNew, org.apache.hadoop.conf.Configuration hconf)
-
-
Method Details
-
delete
- Specified by:
delete
in classBlobStoreFile
- Throws:
IOException
-
isTmp
public boolean isTmp()- Specified by:
isTmp
in classBlobStoreFile
-
getKey
- Specified by:
getKey
in classBlobStoreFile
-
getModTime
- Specified by:
getModTime
in classBlobStoreFile
- Throws:
IOException
-
getInputStream
- Specified by:
getInputStream
in classBlobStoreFile
- Throws:
IOException
-
getOutputStream
- Specified by:
getOutputStream
in classBlobStoreFile
- Throws:
IOException
-
commit
- Specified by:
commit
in classBlobStoreFile
- Throws:
IOException
-
cancel
- Specified by:
cancel
in classBlobStoreFile
- Throws:
IOException
-
toString
-
getFileLength
- Specified by:
getFileLength
in classBlobStoreFile
- Throws:
IOException
-
getMetadata
- Specified by:
getMetadata
in classBlobStoreFile
-
setMetadata
- Specified by:
setMetadata
in classBlobStoreFile
-