@ThreadSafe public class COSUnderFileSystem extends ObjectUnderFileSystem
UnderFileSystem
implementation.ObjectUnderFileSystem.DeleteBuffer, ObjectUnderFileSystem.ObjectListingChunk, ObjectUnderFileSystem.ObjectPermissions, ObjectUnderFileSystem.ObjectStatus, ObjectUnderFileSystem.OperationBuffer<T>, ObjectUnderFileSystem.RenameBuffer
UnderFileSystem.Factory, UnderFileSystem.SpaceType
mExecutorService, mRootKeySupplier, PATH_SEPARATOR, PATH_SEPARATOR_CHAR
mUfsConf, mUri
Modifier | Constructor and Description |
---|---|
protected |
COSUnderFileSystem(AlluxioURI uri,
com.qcloud.cos.COSClient client,
String bucketName,
String appId,
UnderFileSystemConfiguration conf)
Constructor for
COSUnderFileSystem . |
Modifier and Type | Method and Description |
---|---|
protected boolean |
copyObject(String src,
String dst)
Copies an object to another key.
|
boolean |
createEmptyObject(String key)
Creates a zero-byte object used to encode a directory.
|
static COSUnderFileSystem |
createInstance(AlluxioURI uri,
UnderFileSystemConfiguration conf)
Constructs a new instance of
COSUnderFileSystem . |
protected OutputStream |
createObject(String key)
Creates an
OutputStream for object uploads. |
protected boolean |
deleteObject(String key)
Internal function to delete a key.
|
protected String |
getFolderSuffix()
Get suffix used to encode a directory.
|
protected ObjectUnderFileSystem.ObjectListingChunk |
getObjectListingChunk(String key,
boolean recursive)
Gets a (partial) object listing result for the given key.
|
protected ObjectUnderFileSystem.ObjectStatus |
getObjectStatus(String key)
Get metadata information about object.
|
protected ObjectUnderFileSystem.ObjectPermissions |
getPermissions()
Permissions for the mounted bucket.
|
protected String |
getRootKey()
Get full path of root in object store.
|
String |
getUnderFSType()
Returns the name of the under filesystem implementation.
|
boolean |
isDirectory(String path)
Checks if a directory exists in under file system.
|
protected InputStream |
openObject(String key,
OpenOptions options,
RetryPolicy retryPolicy)
Internal function to open an input stream to an object.
|
void |
setMode(String path,
short mode)
Changes posix file mode.
|
void |
setOwner(String path,
String user,
String group)
Sets the user and group of the given path.
|
cleanup, close, connectFromMaster, connectFromWorker, convertToFolderName, create, createNonexistingFile, createNonexistingFile, deleteDirectory, deleteExistingDirectory, deleteExistingDirectory, deleteExistingFile, deleteFile, deleteObjects, getBlockSizeByte, getChildName, getDirectoryStatus, getExistingDirectoryStatus, getExistingFileStatus, getExistingStatus, getFileLocations, getFileLocations, getFileStatus, getListingChunkLength, getListingChunkLengthMax, getObjectListingChunkForPath, getParentPath, getSpace, getStatus, isExistingDirectory, isFile, isObjectStorage, isRoot, listInternal, listStatus, listStatus, mkdirs, mkdirsInternal, open, openExistingFile, openExistingFile, parentExists, renameDirectory, renameFile, renameRenamableDirectory, renameRenamableFile, stripPrefixIfPresent, supportsFlush
create, deleteDirectory, exists, getAclPair, getActiveSyncInfo, getFingerprint, getOperationMode, getPhysicalStores, isSeekable, mkdirs, open, resolveUri, setAclEntries, startActiveSyncPolling, startSync, stopActiveSyncPolling, stopSync, supportsActiveSync, validatePath
protected COSUnderFileSystem(AlluxioURI uri, com.qcloud.cos.COSClient client, String bucketName, String appId, UnderFileSystemConfiguration conf)
COSUnderFileSystem
.uri
- the AlluxioURI
for this UFSclient
- Aliyun COS clientbucketName
- bucket name of user's configured Alluxio bucketconf
- configuration for this UFSpublic static COSUnderFileSystem createInstance(AlluxioURI uri, UnderFileSystemConfiguration conf) throws Exception
COSUnderFileSystem
.uri
- the AlluxioURI
for this UFSconf
- the configuration for this UFSCOSUnderFileSystem
instanceException
public String getUnderFSType()
UnderFileSystem
public void setOwner(String path, String user, String group)
UnderFileSystem
path
- the path of the fileuser
- the new owner to set, unchanged if nullgroup
- the new group to set, unchanged if nullpublic void setMode(String path, short mode)
UnderFileSystem
path
- the path of the filemode
- the mode to set in short format, e.g. 0777protected boolean copyObject(String src, String dst)
ObjectUnderFileSystem
copyObject
in class ObjectUnderFileSystem
src
- the source key to copydst
- the destination key to copy topublic boolean createEmptyObject(String key)
ObjectUnderFileSystem
createEmptyObject
in class ObjectUnderFileSystem
key
- the key to createprotected OutputStream createObject(String key) throws IOException
ObjectUnderFileSystem
OutputStream
for object uploads.createObject
in class ObjectUnderFileSystem
key
- ufs key including scheme and bucketIOException
protected boolean deleteObject(String key)
ObjectUnderFileSystem
deleteObject
in class ObjectUnderFileSystem
key
- the key to deleteprotected String getFolderSuffix()
ObjectUnderFileSystem
getFolderSuffix
in class ObjectUnderFileSystem
protected ObjectUnderFileSystem.ObjectListingChunk getObjectListingChunk(String key, boolean recursive) throws IOException
ObjectUnderFileSystem
getObjectListingChunk
in class ObjectUnderFileSystem
key
- pseudo-directory key excluding header and bucketrecursive
- whether to request immediate children only, or all descendantsIOException
public boolean isDirectory(String path) throws IOException
UnderFileSystem
isDirectory
in interface UnderFileSystem
isDirectory
in class ObjectUnderFileSystem
path
- the absolute directory pathIOException
protected ObjectUnderFileSystem.ObjectStatus getObjectStatus(String key)
ObjectUnderFileSystem
getObjectStatus
in class ObjectUnderFileSystem
key
- ufs key to get metadata forObjectUnderFileSystem.ObjectStatus
if key exists and successful, otherwise nullprotected ObjectUnderFileSystem.ObjectPermissions getPermissions()
ObjectUnderFileSystem
getPermissions
in class ObjectUnderFileSystem
protected String getRootKey()
ObjectUnderFileSystem
getRootKey
in class ObjectUnderFileSystem
protected InputStream openObject(String key, OpenOptions options, RetryPolicy retryPolicy) throws IOException
ObjectUnderFileSystem
openObject
in class ObjectUnderFileSystem
key
- the key to openoptions
- the open optionsretryPolicy
- the retry policy of the opened stream to solve eventual consistency issueInputStream
to read from keyIOException
Copyright © 2023. All Rights Reserved.