@ThreadSafe public class AbfsUnderFileSystem extends HdfsUnderFileSystem
UnderFileSystem.Factory, UnderFileSystem.SpaceType
Modifier and Type | Field and Description |
---|---|
static String |
SCHEME_INSECURE
Constant for the abfs URI scheme.
|
static String |
SCHEME_SECURE
Constant for the abfss URI scheme.
|
mUfsConf, mUri
Constructor and Description |
---|
AbfsUnderFileSystem(AlluxioURI ufsUri,
UnderFileSystemConfiguration conf,
org.apache.hadoop.conf.Configuration hdfsConf)
Constructs a new HDFS
UnderFileSystem . |
Modifier and Type | Method and Description |
---|---|
static AbfsUnderFileSystem |
createInstance(AlluxioURI uri,
UnderFileSystemConfiguration conf)
Creates a new
AbfsUnderFileSystem instance. |
long |
getBlockSizeByte(String path)
Gets the block size of a file in under file system, in bytes.
|
List<String> |
getFileLocations(String path)
Gets the list of locations of the indicated path.
|
List<String> |
getFileLocations(String path,
FileLocationOptions options)
Gets the list of locations of the indicated path given options.
|
UfsStatus |
getStatus(String path)
Gets the file or directory status.
|
String |
getUnderFSType()
Returns the name of the under filesystem implementation.
|
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, create, createConfiguration, createDirect, deleteDirectory, deleteFile, exists, getAclPair, getActiveSyncInfo, getDirectoryStatus, getFileStatus, getSpace, isDirectory, isFile, isSeekable, listStatus, mkdirs, open, renameDirectory, renameFile, setAclEntries, startActiveSyncPolling, startSync, stopActiveSyncPolling, stopSync, supportsActiveSync, supportsFlush
createNonexistingFile, createNonexistingFile, deleteExistingDirectory, deleteExistingDirectory, deleteExistingFile, getExistingDirectoryStatus, getExistingFileStatus, getExistingStatus, isExistingDirectory, openExistingFile, openExistingFile, renameRenamableDirectory, renameRenamableFile
create, deleteDirectory, getConfiguration, getFingerprint, getOperationMode, getPhysicalStores, isObjectStorage, listStatus, mkdirs, open, resolveUri, validatePath
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
create, createNonexistingFile, createNonexistingFile, deleteDirectory, deleteExistingDirectory, deleteExistingDirectory, deleteExistingFile, getConfiguration, getExistingDirectoryStatus, getExistingFileStatus, getExistingStatus, getFingerprint, getOperationMode, getPhysicalStores, isExistingDirectory, isObjectStorage, listStatus, mkdirs, open, openExistingFile, openExistingFile, renameRenamableDirectory, renameRenamableFile, resolveUri
public static final String SCHEME_INSECURE
public static final String SCHEME_SECURE
public AbfsUnderFileSystem(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 HDFSpublic static AbfsUnderFileSystem createInstance(AlluxioURI uri, UnderFileSystemConfiguration conf)
AbfsUnderFileSystem
instance.uri
- the alluxio uriconf
- the ufs configurationpublic String getUnderFSType()
UnderFileSystem
getUnderFSType
in interface UnderFileSystem
getUnderFSType
in class HdfsUnderFileSystem
public long getBlockSizeByte(String path) throws IOException
UnderFileSystem
getBlockSizeByte
in interface UnderFileSystem
getBlockSizeByte
in class HdfsUnderFileSystem
path
- the file nameIOException
public UfsStatus getStatus(String path) throws IOException
UnderFileSystem
getStatus
in interface UnderFileSystem
getStatus
in class HdfsUnderFileSystem
path
- the path to get the statusFileNotFoundException
- when the path does not existIOException
public void setOwner(String path, String user, String group)
UnderFileSystem
setOwner
in interface UnderFileSystem
setOwner
in class HdfsUnderFileSystem
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
setMode
in interface UnderFileSystem
setMode
in class HdfsUnderFileSystem
path
- the path of the filemode
- the mode to set in short format, e.g. 0777public List<String> getFileLocations(String path) throws IOException
UnderFileSystem
getFileLocations
in interface UnderFileSystem
getFileLocations
in class HdfsUnderFileSystem
path
- the file nameIOException
public List<String> getFileLocations(String path, FileLocationOptions options) throws IOException
UnderFileSystem
getFileLocations
in interface UnderFileSystem
getFileLocations
in class HdfsUnderFileSystem
path
- the file nameoptions
- method optionsIOException
Copyright © 2023. All Rights Reserved.