public class BmcFilesystem extends FileSystem
FileSystem that is backed by the BMC Object Store.
Filesystems using this store take the URI form: oci://bucket@namespace. The bucket must be pre-created.
Unless otherwise noted, APIs try to follow the specification as defined by:
http://hadoop.apache.org/docs/current/hadoop-project-dist/hadoop-common/filesystem/filesystem.html
This is the proxy for the actual implementation, BmcFilesystemImpl, which may be cached.
FileSystem.DirectoryEntries, FileSystem.DirListingIterator<T extends FileStatus>, FileSystem.StatisticsDEFAULT_FS, FS_DEFAULT_NAME_KEY, SHUTDOWN_HOOK_PRIORITY, statistics, TRASH_PREFIX, USER_HOME_PREFIX| Constructor and Description |
|---|
BmcFilesystem() |
access, append, append, appendFile, areSymlinksEnabled, cancelDeleteOnExit, canonicalizeUri, checkPath, clearStatistics, closeAll, closeAllForUGI, completeLocalOutput, concat, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyFromLocalFile, copyToLocalFile, copyToLocalFile, copyToLocalFile, create, create, create, create, create, create, create, create, create, create, create, create, createDataInputStreamBuilder, createDataInputStreamBuilder, createDataOutputStreamBuilder, createFile, createMultipartUploader, createNewFile, createNonRecursive, createNonRecursive, createPathHandle, createSnapshot, createSnapshot, createSymlink, delete, deleteOnExit, deleteSnapshot, enableSymlinks, exists, fixRelativePart, get, get, get, getAclStatus, getAdditionalTokenIssuers, getAllStatistics, getAllStoragePolicies, getBlockSize, getCanonicalUri, getChildFileSystems, getDefaultBlockSize, getDefaultReplication, getDefaultReplication, getDefaultUri, getDelegationToken, getFileBlockLocations, getFileBlockLocations, getFileChecksum, getFileChecksum, getFileLinkStatus, getFileSystemClass, getFSofPath, getGlobalStorageStatistics, getHomeDirectory, getInitialWorkingDirectory, getLength, getLinkTarget, getLocal, getName, getNamed, getPathHandle, getQuotaUsage, getReplication, getServerDefaults, getServerDefaults, getStatistics, getStatistics, getStatus, getStatus, getStoragePolicy, getStorageStatistics, getTrashRoot, getTrashRoots, getUsed, getUsed, getXAttr, getXAttrs, getXAttrs, globStatus, globStatus, hasPathCapability, isDirectory, isFile, listCorruptFileBlocks, listLocatedStatus, listLocatedStatus, listStatus, listStatus, listStatus, listStatusBatch, listStatusIterator, listXAttrs, makeQualified, mkdirs, mkdirs, modifyAclEntries, moveFromLocalFile, moveFromLocalFile, moveToLocalFile, msync, newInstance, newInstance, newInstance, newInstanceLocal, open, open, open, openFile, openFile, openFileWithOptions, openFileWithOptions, primitiveCreate, primitiveMkdir, primitiveMkdir, printStatistics, processDeleteOnExit, removeAcl, removeAclEntries, removeDefaultAcl, removeXAttr, rename, renameSnapshot, resolveLink, resolvePath, satisfyStoragePolicy, setAcl, setDefaultUri, setDefaultUri, setOwner, setPermission, setQuota, setQuotaByStorageType, setReplication, setStoragePolicy, setTimes, setVerifyChecksum, setWriteChecksum, setXAttr, setXAttr, startLocalOutput, supportsSymlinks, truncate, unsetStoragePolicysetConfclone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitaddDelegationTokens, collectDelegationTokensprotected com.oracle.bmc.hdfs.BmcFilesystemImpl getDelegate()
public void initialize(URI uri, Configuration configuration) throws IOException
initialize in class FileSystemIOExceptionpublic String getScheme()
getScheme in class FileSystempublic FSDataOutputStream append(Path path, int bufferSize, Progressable progress) throws IOException
append in class FileSystemIOExceptionpublic FSDataOutputStream create(Path path, org.apache.hadoop.fs.permission.FsPermission permission, boolean overwrite, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
create in class FileSystemIOExceptionpublic FSDataOutputStream createNonRecursive(Path f, org.apache.hadoop.fs.permission.FsPermission permission, EnumSet<CreateFlag> flags, int bufferSize, short replication, long blockSize, Progressable progress) throws IOException
createNonRecursive in class FileSystemIOExceptionpublic boolean delete(Path path, boolean recursive) throws IOException
delete in class FileSystemIOExceptionpublic ContentSummary getContentSummary(Path path) throws IOException
getContentSummary in class FileSystemIOExceptionpublic FileStatus getFileStatus(Path path) throws IOException
getFileStatus in class FileSystemIOExceptionpublic FileStatus[] listStatus(Path path) throws IOException
listStatus in class FileSystemIOExceptionpublic boolean mkdirs(Path path, org.apache.hadoop.fs.permission.FsPermission permission) throws IOException
mkdirs in class FileSystemIOExceptionpublic FSDataInputStream open(Path path, int bufferSize) throws IOException
open in class FileSystemIOExceptionpublic boolean rename(Path source, Path destination) throws IOException
rename in class FileSystemIOExceptionpublic long getDefaultBlockSize()
getDefaultBlockSize in class FileSystempublic int getDefaultPort()
getDefaultPort in class FileSystempublic String getCanonicalServiceName()
getCanonicalServiceName in interface DelegationTokenIssuergetCanonicalServiceName in class FileSystempublic void close()
throws IOException
close in interface Closeableclose in interface AutoCloseableclose in class FileSystemIOExceptionpublic Path getWorkingDirectory()
getWorkingDirectory in class FileSystempublic void setWorkingDirectory(Path workingDirectory)
setWorkingDirectory in class FileSystempublic URI getUri()
getUri in class FileSystempublic BmcDataStore getDataStore()
public Configuration getConf()
getConf in interface ConfigurablegetConf in class Configuredpublic RemoteIterator<LocatedFileStatus> listFiles(Path f, boolean recursive) throws FileNotFoundException, IOException
listFiles in class FileSystemFileNotFoundExceptionIOExceptionCopyright © 2016–2023. All rights reserved.