@ThreadSafe public class CephfsHadoopUnderFileSystem extends HdfsUnderFileSystem
UnderFileSystem
implementation.UnderFileSystem.Factory, UnderFileSystem.SpaceType
CHECKSUM_COMBINE_MODE, HADOOP_AUTH_METHOD, HDFS_ACL_PROVIDER_CLASS, HDFS_EC_CODEC_REGISTRY_CLASS, HDFS_EC_MIN_VERSION, HDFS_USER, JAVAX_WS_RS_CORE_MEDIA_TYPE, KRB_KEYTAB_LOGIN_AUTO_RENEW, KRB5_CONF_FILE, MAX_TRY, mHdfsAclProvider
EMPTY_ACL, mUfsConf, mUri
Constructor and Description |
---|
CephfsHadoopUnderFileSystem(AlluxioURI ufsUri,
UnderFileSystemConfiguration conf,
org.apache.hadoop.conf.Configuration hdfsConf)
Constructs a new Cephfs-Hadoop
UnderFileSystem . |
Modifier and Type | Method and Description |
---|---|
static CephfsHadoopUnderFileSystem |
createInstance(AlluxioURI ufsUri,
UnderFileSystemConfiguration conf)
Factory method to constructs a new cephfs-hadoop
UnderFileSystem instance. |
String |
getUnderFSType()
Returns the name of the under filesystem implementation.
|
cleanup, close, connectFromMaster, connectFromWorker, create, createConfiguration, createDirect, deleteDirectory, deleteFile, exists, getAclPair, getBlockSizeByte, getDirectoryStatus, getFileLocations, getFileLocations, getFileStatus, getFs, getSpace, getStatus, isDirectory, isFile, isSeekable, listStatus, mkdirs, open, openPositionRead, renameDirectory, renameFile, setAclEntries, setMode, setOwner, supportsFlush
createNonexistingFile, createNonexistingFile, deleteExistingDirectory, deleteExistingDirectory, deleteExistingFile, getExistingDirectoryStatus, getExistingFileStatus, getExistingStatus, isExistingDirectory, openExistingFile, openExistingFile, renameRenamableDirectory, renameRenamableFile
create, deleteDirectory, getConfiguration, getFingerprint, getOperationMode, getParsedFingerprint, getParsedFingerprint, getPhysicalStores, isObjectStorage, listStatus, listStatusIterable, mkdirs, open, performListingAsync, resolveUri, validatePath
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
create, createNonexistingFile, createNonexistingFile, deleteDirectory, deleteExistingDirectory, deleteExistingDirectory, deleteExistingFile, getConfiguration, getExistingDirectoryStatus, getExistingFileStatus, getExistingStatus, getFileStatus, getFingerprint, getOperationMode, getParsedFingerprint, getParsedFingerprint, getPhysicalStores, getStatus, getTemporaryToken, isExistingDirectory, isObjectStorage, isTemporaryConnectionToken, listStatus, listStatuses, listStatusIterable, mkdirs, open, openExistingFile, openExistingFile, refreshTemporaryToken, renameRenamableDirectory, renameRenamableFile, resolveUri, setTemporaryTokenRefreshContext
performListingAsync
public CephfsHadoopUnderFileSystem(AlluxioURI ufsUri, UnderFileSystemConfiguration conf, org.apache.hadoop.conf.Configuration hdfsConf)
UnderFileSystem
.ufsUri
- the AlluxioURI
for this UFSconf
- the configuration for this UFShdfsConf
- the configuration for Cephfs-Hadooppublic static CephfsHadoopUnderFileSystem createInstance(AlluxioURI ufsUri, UnderFileSystemConfiguration conf)
UnderFileSystem
instance.ufsUri
- the AlluxioURI
for this UFSconf
- the configuration for HadoopUnderFileSystem
instancepublic String getUnderFSType()
UnderFileSystem
getUnderFSType
in interface UnderFileSystem
getUnderFSType
in class HdfsUnderFileSystem
Copyright © 2023. All Rights Reserved.