alluxio.underfs.ozone

Class OzoneUnderFileSystem

java.lang.Object

alluxio.underfs.BaseUnderFileSystem

alluxio.underfs.ConsistentUnderFileSystem

alluxio.underfs.hdfs.HdfsUnderFileSystem

alluxio.underfs.ozone.OzoneUnderFileSystem

All Implemented Interfaces:

AtomicFileOutputStreamCallback, UnderFileSystem, Closeable, AutoCloseable

@ThreadSafe
public class OzoneUnderFileSystem
extends HdfsUnderFileSystem

Ozone UnderFileSystem implementation.

Nested Class Summary

Nested classes/interfaces inherited from interface alluxio.underfs.UnderFileSystem

UnderFileSystem.Factory, UnderFileSystem.SpaceType

Field Summary

Fields inherited from class alluxio.underfs.BaseUnderFileSystem

EMPTY_ACL, mUfsConf, mUri

Constructor Summary

Constructors

Constructor and Description
OzoneUnderFileSystem(AlluxioURI ufsUri, UnderFileSystemConfiguration conf, org.apache.hadoop.conf.Configuration hdfsConf) Constructs a new Ozone UnderFileSystem.

Method Summary

Modifier and Type	Method and Description
static OzoneUnderFileSystem	createInstance(AlluxioURI ufsUri, UnderFileSystemConfiguration conf) Factory method to constructs a new Ozone UnderFileSystem instance.
String	getUnderFSType() Returns the name of the under filesystem implementation.

Methods inherited from class alluxio.underfs.hdfs.HdfsUnderFileSystem

cleanup, close, connectFromMaster, connectFromWorker, create, createConfiguration, createDirect, deleteDirectory, deleteFile, exists, getAclPair, getActiveSyncInfo, getBlockSizeByte, getDirectoryStatus, getFileLocations, getFileLocations, getFileStatus, getSpace, getStatus, isDirectory, isFile, isSeekable, listStatus, mkdirs, open, renameDirectory, renameFile, setAclEntries, setMode, setOwner, startActiveSyncPolling, startSync, stopActiveSyncPolling, stopSync, supportsActiveSync, supportsFlush

Methods inherited from class alluxio.underfs.ConsistentUnderFileSystem

createNonexistingFile, createNonexistingFile, deleteExistingDirectory, deleteExistingDirectory, deleteExistingFile, getExistingDirectoryStatus, getExistingFileStatus, getExistingStatus, isExistingDirectory, openExistingFile, openExistingFile, renameRenamableDirectory, renameRenamableFile

Methods inherited from class alluxio.underfs.BaseUnderFileSystem

create, deleteDirectory, getConfiguration, getFingerprint, getOperationMode, getParsedFingerprint, getParsedFingerprint, getPhysicalStores, isObjectStorage, listStatus, mkdirs, open, resolveUri, validatePath

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface alluxio.underfs.UnderFileSystem

create, createNonexistingFile, createNonexistingFile, deleteDirectory, deleteExistingDirectory, deleteExistingDirectory, deleteExistingFile, getConfiguration, getExistingDirectoryStatus, getExistingFileStatus, getExistingStatus, getFingerprint, getOperationMode, getParsedFingerprint, getParsedFingerprint, getPhysicalStores, isExistingDirectory, isObjectStorage, listStatus, mkdirs, open, openExistingFile, openExistingFile, renameRenamableDirectory, renameRenamableFile, resolveUri

Constructor Detail

OzoneUnderFileSystem

public OzoneUnderFileSystem(AlluxioURI ufsUri,
                            UnderFileSystemConfiguration conf,
                            org.apache.hadoop.conf.Configuration hdfsConf)

Constructs a new Ozone UnderFileSystem.

Parameters:

ufsUri - the AlluxioURI for this UFS

conf - the configuration for this UFS

hdfsConf - the configuration for Ozone

Method Detail

createInstance

public static OzoneUnderFileSystem createInstance(AlluxioURI ufsUri,
                                                  UnderFileSystemConfiguration conf)

Factory method to constructs a new Ozone UnderFileSystem instance.

Parameters:

ufsUri - the AlluxioURI for this UFS

conf - the configuration for Hadoop

Returns:

a new Ozone UnderFileSystem instance

getUnderFSType

public String getUnderFSType()

Description copied from interface: UnderFileSystem

Returns the name of the under filesystem implementation. The name should be lowercase and not include any spaces, e.g. "hdfs", "s3".

Specified by:

getUnderFSType in interface UnderFileSystem

Overrides:

getUnderFSType in class HdfsUnderFileSystem

Returns:

name of the under filesystem implementation