public class KodoUnderFileSystem 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 |
KodoUnderFileSystem(AlluxioURI uri,
KodoClient kodoclient,
UnderFileSystemConfiguration conf) |
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.
|
protected OutputStream |
createObject(String key)
Creates an
OutputStream for object uploads. |
protected static KodoUnderFileSystem |
creatInstance(AlluxioURI uri,
UnderFileSystemConfiguration conf) |
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)
Gets metadata information about object.
|
protected ObjectUnderFileSystem.ObjectPermissions |
getPermissions()
Permissions for the mounted bucket.
|
protected String |
getRootKey()
Gets full path of root in object store.
|
String |
getUnderFSType()
Returns the name of the under filesystem implementation.
|
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, isDirectory, 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 KodoUnderFileSystem(AlluxioURI uri, KodoClient kodoclient, UnderFileSystemConfiguration conf)
protected static KodoUnderFileSystem creatInstance(AlluxioURI uri, UnderFileSystemConfiguration conf)
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) throws IOException
UnderFileSystem
path
- the path of the filemode
- the mode to set in short format, e.g. 0777IOException
protected 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
@Nullable 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
@Nullable protected ObjectUnderFileSystem.ObjectStatus getObjectStatus(String key)
getObjectStatus
in class ObjectUnderFileSystem
key
- ufs key to get metadata forObjectStatus
if key exists and successful, otherwise nullprotected ObjectUnderFileSystem.ObjectPermissions getPermissions()
ObjectUnderFileSystem
getPermissions
in class ObjectUnderFileSystem
protected InputStream openObject(String key, OpenOptions options, RetryPolicy retryPolicy)
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 keyprotected String getRootKey()
getRootKey
in class ObjectUnderFileSystem
Copyright © 2023. All Rights Reserved.